Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
KTable Reduce Allow Null value to be pass in Subtractor.
.reduce((aggValue, newValue) -> addCounts(aggValue, newValue),
(aggValue, oldValue) -> subtractCounts(aggValue, oldValue))
aggValue passed by org.apache.kafka.streams.kstream.internals.KTableReduce.java is null.
Please find attached Exception Trace.