[
https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036099#comment-17036099
]
Bruno Cadonna commented on KAFKA-9533:
--------------------------------------
Thank you for picking this up!
Ad 1) We do not support backwards compatibility of bugs. The documentation is
clear, we just failed to implement it correctly.
Ad 2) If you want to try to simplify the code with the adapter as in
{{transform()}} and {{flatTransform()}} you are very welcome to do so. For a
smoother review process, I would like to ask you to create two PRs, one for the
refactoring and one for the bug fix.
Are you able to assign the ticket to yourself?
> 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)
