Module dataflow::sink::kafka

Structs

EncodedRow

KafkaConsistencyInitState

KafkaConsistencyRunningState

KafkaSinkState

KafkaSinkToken

KafkaTxProducer

SinkMetrics

Per-Kafka sink metrics.

SinkProducerContext

Enums

KafkaSinkStateEnum

Functions

encode_stream

Encodes a stream of (Option<Row>, Option<Row>) updates using the specified encoder.

kafka

produce_to_kafka

Produces/sends a stream of encoded rows (as Vec<u8>) to Kafka.