HARSHIT AGARWAL created KAFKA-7905: -------------------------------------- Summary: KTable Reduce Allow Null value to be pass in Subtractor Key: KAFKA-7905 URL: https://issues.apache.org/jira/browse/KAFKA-7905 Project: Kafka Issue Type: Bug Components: streams Reporter: HARSHIT AGARWAL Attachments: KTableReduceExceptionTrace.txt
KTable Reduce Allow Null value to be pass in Subtractor. .reduce((aggValue, newValue) -> addCounts(aggValue, newValue), (aggValue, oldValue) -> subtractCounts(*{color:#FF0000}aggValue{color}*, oldValue)) *{color:#FF0000}aggValue{color}* passed by *{color:#FF0000}{color}* org.apache.kafka.streams.kstream.internals.KTableReduce.java is {color:#FF0000}*null*{color}. Please find attached Exception Trace. -- This message was sent by Atlassian JIRA (v7.6.3#76005)