[
https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544717#comment-16544717
]
Matthias J. Sax commented on KAFKA-7161:
----------------------------------------
PR: [https://github.com/apache/kafka/pull/5366]
[~guozhang] That was a discussion on the user-mailing list. Subject: `Re:
Kafka-streams calling subtractor with null aggregator value in
KGroupedTable.reduce() and other weirdness`
> 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)
