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

Posted to jira@kafka.apache.org by "Michael Viamari (Jira)" <ji...@apache.org> on 2020/02/10 19:32:00 UTC

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

Michael Viamari created KAFKA-9533:
--------------------------------------

             Summary: 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


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#transform` 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)