Skip to main content

Module api

crabka_client_streams::processor

Module api

Expand description

The typed Processor API: Processor, ProcessorSupplier, and the ProcessorContext users call forward on.

Structs§

ProcessorContext: Handed to Processor::process. forward boxes the record and queues it for each child node (the driver drains the queue).

Traits§

Processor: A stateless record processor. One instance is created per task via ProcessorSupplier::get. Mirrors org.apache.kafka.streams.processor.api.Processor.
ProcessorSupplier: Factory for Processor instances (one per task → per-task isolation).