Dmitry Minkovsky created KAFKA-3901:
---------------------------------------
Summary:
KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null
values
Key: KAFKA-3901
URL: https://issues.apache.org/jira/browse/KAFKA-3901
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 0.10.0.0
Reporter: Dmitry Minkovsky
Assignee: Guozhang Wang
Priority: Minor
Did this get missed in [KAFKA-3519: Refactor Transformer's transform /
punctuate to return nullable
value|https://github.com/apache/kafka/commit/40fd456649b5df29d030da46865b5e7e0ca6db15#diff-338c230fd5a15d98550230007651a224]?
I think it may have, because that processor's #punctuate() does not forward
null.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
