[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

["Bruno Cadonna (Jira)" <ji...@apache.org>]

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

Bruno Cadonna commented on KAFKA-9533:
--------------------------------------

[~mviamari] Thank you for opening this ticket. This seems to be a bug indeed.

> ValueTransform forwards `null` values
> -------------------------------------
>
>                 Key: KAFKA-9533
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9533
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 2.4.0
>            Reporter: Michael Viamari
>            Priority: Minor
>
> According to the documentation for `KStream#transformValues`, nulls returned from `ValueTransformer#transform` are not forwarded. (see [KStream#transformValues|https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/kstream/KStream.html#transformValues-org.apache.kafka.streams.kstream.ValueTransformerSupplier-java.lang.String...-]
> However, this does not appear to be the case. In `KStreamTransformValuesProcessor#process` the result of the transform is forwarded directly.
> {code:java}
>  @Override
>  public void process(final K key, final V value) {
>      context.forward(key, valueTransformer.transform(key, value));
>  }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)