Module mz_compute::sink::kafka

Structs

EncodedRow 🔒

KafkaConsistencyInitState 🔒

KafkaConsistencyRunningState 🔒

KafkaSinkSendRetryManager

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.