[
https://issues.apache.org/jira/browse/KAFKA-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15348624#comment-15348624
]
Dmitry Minkovsky commented on KAFKA-3901:
-----------------------------------------
...and KStreamTransform$KStreamTransformProcessor#process() does not forward
null values.
Anyway, I marked this minor because I can use the non-value process, so there
is a workaround.
> 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)
