[
https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035927#comment-17035927
]
Michael Viamari commented on KAFKA-9533:
----------------------------------------
Sure. I can take a look at it. Before I get started:
1) How should I think about the case where someone might unintentionally (or
intentionally) be relying on the buggy behavior? Is that something I should
handle in code, or is it handled elsewhere?
2) I noticed that KStream#transform uses an adaptor to conform to
KStream#flatTransform. Should I do something similar for
KStream#transformValues and KStream#flatTransformValues, since I will be
modifying that area of code already?
> 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)
