Matthias J. Sax created KAFKA-4619: -------------------------------------- Summary: Dissallow to output records with unknown keys in TransformValues Key: KAFKA-4619 URL: https://issues.apache.org/jira/browse/KAFKA-4619 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.1.1, 0.10.0.1, 0.10.0.0, 0.10.1.0 Reporter: Matthias J. Sax Assignee: Matthias J. Sax Fix For: 0.10.2.0
{{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. -- This message was sent by Atlassian JIRA (v6.3.4#6332)