Module dataflow::source::kafka

Structs

GlueConsumerContext

An implementation of ConsumerContext that forwards statistics to the worker

KafkaSourceReader

Contains all information necessary to ingest data from Kafka

PartitionConsumer

Wrapper around a partition containing the underlying consumer

Functions

create_kafka_config

Creates a Kafka config.

get_kafka_partitions

Return the list of partition ids associated with a specific topic