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)
