Struct KafkaStreamSink 

pub struct KafkaStreamSink<R>
where
    R: Clone + Send + Sync + 'static,
{ /* private fields */ }

Kafka stream sink that receives results from the pipeline

This component receives aggregated results from the stream processing pipeline and produces them to a Kafka topic. It handles:

• Message serialization
• Delivery guarantees
• Retries on failure
• Error handling

Implementations

impl<R> KafkaStreamSink<R>

where R: Clone + Send + Sync + 'static + Serialize + for<'de> Deserialize<'de>,

pub fn new( producer: Arc<FutureProducer>, output_topic: String, result_rx: Receiver<ProcessorEvent<R>>, stats: Arc<RwLock<KafkaStreamStats>>, delivery_timeout: Duration, max_retries: u32, ) -> Self

Create a new Kafka stream sink

pub async fn run(&self) -> Result<()>

Start consuming results and producing to Kafka

pub fn stop(&self)

Stop the sink

pub fn is_running(&self) -> bool

Check if running

pub async fn stats(&self) -> KafkaStreamStats

Get statistics