[jira] [Created] (KAFKA-7161) KTable Reduce should check for invalid conditions

[John Roesler (JIRA)]

John Roesler created KAFKA-7161:
-----------------------------------

             Summary: KTable Reduce should check for invalid conditions
                 Key: KAFKA-7161
                 URL: https://issues.apache.org/jira/browse/KAFKA-7161
             Project: Kafka
          Issue Type: Improvement
            Reporter: John Roesler
            Assignee: John Roesler


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)