Module dataflow::source::kafka [−][src]
Structs
An implementation of ConsumerContext
that forwards statistics to the
worker
Contains all information necessary to ingest data from Kafka
Wrapper around a partition containing the underlying consumer
Functions
Creates a Kafka config.
Return the list of partition ids associated with a specific topic