Module source 

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

Structs

KafkaMetadataColumns

The metadata columns a source appends, in canonical order without duplicates.

KafkaSource

Kafka source connector that consumes messages and produces Arrow batches.

Enums

KafkaMetadataColumn

One selectable metadata column, in canonical output order.