[KAFKA-7905] KTable Reduce Allow Null value to be pass in Subtractor

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Labels: user-experience
• Assignee: Unassigned
• Reporter: HARSHIT AGARWAL
• Created: 07/Feb/19 04:53
• Updated: 08/Feb/19 01:21

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.