Expand description
Kafka source connector implementation.
KafkaSource implements the SourceConnector trait, consuming
from Kafka topics via rdkafka’s StreamConsumer, deserializing
messages using pluggable formats, and producing Arrow RecordBatch
data through the connector SDK.
Structs§
- Kafka
Source - Kafka source connector that consumes messages and produces Arrow batches.