Skip to main content

Module api

krabka_client_streams::processor

Module api

Expand description

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

Structs§

ProcessorContext: The context handed to Processor::process. forward boxes the record and queues it for each child node, and the driver drains the queue.

Traits§

Processor: A stateless record processor. ProcessorSupplier::get creates one instance per task. This mirrors org.apache.kafka.streams.processor.api.Processor.
ProcessorSupplier: Factory for Processor instances. It makes one instance per task, which gives per-task isolation.