[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494692#comment-16494692 ]
Jagadesh Adireddi commented on KAFKA-6906: ------------------------------------------ [~mjsax], should we keep using `commitOffsetNeeded` flag and proceed further to fix this bug. And push point 3 and 4 code changes to another Jira?. > Kafka Streams does not commit transactions if data is produced via wall-clock > punctuation > ----------------------------------------------------------------------------------------- > > Key: KAFKA-6906 > URL: https://issues.apache.org/jira/browse/KAFKA-6906 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 1.1.0 > Reporter: Matthias J. Sax > Assignee: Jagadesh Adireddi > Priority: Major > > Committing in Kafka Streams happens in regular intervals. However, committing > only happens if new input records got processed since the last commit (via > setting flag `commitOffsetNeeded` within `StreamTask#process()`) > However, data could also be emitted via wall-clock based punctuation calls. > Especially if EOS is enabled, this is an issue (maybe also for non-EOS) > because the current running transaction is not committed and thus might time > out leading to a fatal error. -- This message was sent by Atlassian JIRA (v7.6.3#76005)