Module fixed_key 

Fixed-key Processor API (KIP-820 processValues).

A fixed-key processor may change the value but NOT the key. This module is a thin typed facade over the regular Processor runtime. An internal adapter bridges a FixedKeyProcessor into a Processor<KIn, VIn, KIn, VOut>. The output key type equals the input key type, so the runtime keeps the partition assignment unchanged.

The DSL surface KStream::process_values wraps a FixedKeyProcessorSupplier in that adapter. This module holds the typed facade and the adapter that it builds on.

Structs

FixedKeyProcessorContext

The context handed to FixedKeyProcessor::process.

FixedKeyRecord

A record whose KEY is immutable.

Traits

FixedKeyProcessor

A fixed-key record processor (KIP-820).

FixedKeyProcessorSupplier

Factory for FixedKeyProcessor instances.