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)