Hi Dev team,

I'd like to start a new discussion thread on Kafka Streams KIP-820:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-820%3A+Extend+KStream+process+with+new+Processor+API

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.

Looking forward to your feedback.

Regards,
Jorge.

Reply via email to