Details
Major Description
KStream#transformValues allows the user to return a new value in punctuate and it also allows the user to return any new key value pair using ProcesserContext#forward. For punctuate the key gets set to null under the hood and for forward the user can put any new key they want. However, Kafka Streams assumes that using transformValue does not change the key – thus, this assumption might not hold right now resulting potentially incorrectly partitioned data.
Thus, it should not be possible to return any data in punctuate and forward and we should raise an exception.
Attachments
Issue Links
- links to
