[ https://issues.apache.org/jira/browse/KAFKA-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651775#comment-15651775 ]
Guozhang Wang commented on KAFKA-3901: -------------------------------------- [~dminkovsky] The motivation of KAFKA-3519 is that, if user's defined `transform` or `punctuate` function returns {{null}}, it indicates users do not want to forward any data downstream. In other words, {{null}} is not used as a special value but as a signal to indicate "no output". Could you describe your scenario where you would need {{<key, null>}} as a special record? > 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)