KIP-820 — Extend KStream process with new Processor API

Accepted Kafka 3.3 Streams

Extends KStream with a process(ProcessorSupplier, Named, String...) method that integrates the new strongly-typed Processor API (KIP-478) directly into the DSL, replacing the legacy transform() and transformValues() methods with a unified processing operator. The existing Transformer-based operators were tied to the old ProcessorContext, lacked support for one-to-many output, and required multiple overlapping DSL methods to cover different combinations of value/key/context access.

Details