Page History

...

Transformers are currently limited to the old ProcessorContext. With the addition of the new Processor API, KStream can be extended to offer access to the new, chainable API that can replace most of the operations transformers offer at the moment, with more open control to forward records.

This KIP is aimed to extend the current `KStream#process` API to return output values that could be chained across the topology, as well as introducing a new `KStream#processValues` to use processor while validating keys haven't change and repartition is not required.

This KIP could be considered as a step towards deprecating Transforms, though that should be discussed in a follow-up KIP.

...