Module source 

Kafka source connector: consumes topics via rdkafka’s StreamConsumer, deserializes with pluggable formats, and yields Arrow RecordBatches.

Structs

KafkaSource

Kafka source connector that consumes messages and produces Arrow batches.