You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "John Roesler (JIRA)" <ji...@apache.org> on 2018/07/13 18:03:01 UTC

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

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)