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

Posted to jira@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/07/14 21:22:00 UTC

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

    [ https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544342#comment-16544342 ] 

Guozhang Wang commented on KAFKA-7161:
--------------------------------------

Not sure if I can completely follow the description. To me the {{oldValues}} received from the upstream operator does not necessarily need to be the same as the reducer associated state stores.

> 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
>            Priority: Major
>
> 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)