[jira] [Updated] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

["Matthias J. Sax (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax updated KAFKA-6906:
-----------------------------------
    Fix Version/s: 1.0.2
                   0.11.0.3

> 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
>             Fix For: 2.0.0, 0.11.0.3, 1.0.2, 1.1.1
>
>
> 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)