Expand description
Kafka sink connector implementation.
KafkaSink implements the SinkConnector trait, writing Arrow
RecordBatch data to Kafka topics via rdkafka’s FutureProducer.
Supports at-least-once (idempotent) and exactly-once (transactional)
delivery, configurable partitioning, and dead-letter queue routing.
Structs§
- Kafka
Sink - Kafka sink connector that writes Arrow
RecordBatchdata to Kafka topics.