You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/11/09 00:07:58 UTC

[jira] [Commented] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values

    [ https://issues.apache.org/jira/browse/KAFKA-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15649270#comment-15649270 ] 

Dmitry Minkovsky commented on KAFKA-3901:
-----------------------------------------

Also affects 0.10.1.0 <3

> 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)