[KAFKA-7161] KTable Reduce should check for invalid conditions

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Assignee: John Roesler
• Reporter: John Roesler
• Created: 13/Jul/18 18:02
• Updated: 01/Aug/18 18:02
• Resolved: 01/Aug/18 18:02

Description

KTableReduce has the opportunity to explicitly check if the state is inconsistent with the oldValues arriving from the stream. If it did so, it could help detect topology changes that needed an app reset and fail fast before any data corruption occurs.

Issue Links

• links to: GitHub Pull Request #5366