Module sink 

Kafka Sink for publishing processed results

This module provides a high-performance, production-ready Kafka producer with support for batching, compression, transactions, and exactly-once semantics.

Structs

BincodeSerializer

Bincode serializer

JsonSerializer

JSON serializer

KafkaMessage

Message to be sent to Kafka

KafkaSink

Kafka sink for publishing messages

KafkaSinkConfig

Configuration for Kafka sink

SinkMetrics

Production metrics

Enums

DeliveryGuarantee

Delivery guarantee level

PartitionStrategy

Partitioning strategy for messages

Traits

MessageSerializer

Serializer trait for converting messages to bytes