You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2020/03/13 21:30:00 UTC
[jira] [Commented] (KAFKA-9533) JavaDocs of KStream#ValueTransform
incorrect
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059086#comment-17059086 ]
Matthias J. Sax commented on KAFKA-9533:
----------------------------------------
The incorrect JavaDocs were introduced via [https://github.com/apache/kafka/commit/05668e98f531cf4d6ddb0696f0f72675ca128581] – ie, only 2.3.0 and newer is affected.
> JavaDocs of KStream#ValueTransform incorrect
> --------------------------------------------
>
> Key: KAFKA-9533
> URL: https://issues.apache.org/jira/browse/KAFKA-9533
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.3.0
> Reporter: Michael Viamari
> Assignee: Matthias J. Sax
> Priority: Major
>
> 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)