[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bill Bejeck updated KAFKA-6367: ------------------------------- Description: {{StateRestoreListener#restoreBatchCompleted}} takes the {{nextPosition}} longĀ for the batch ending offset, but the {{nextPosition}} is not correct, it should be the offset of the latest restored offset, but {{nextPosition}} is the offset of the first not restored offset. We can't automatically use {{nextPosition}} - 1 as this could be a commit marker. was: {{StateRestoreListener#restoreBatchCompleted}} takes the {{nextPosition}} long but the {{nextPosition}} is not correct, it should be the offset of the latest restored offset, but {{nextPosition}} is the offset of the first not restored offset. We can't automatically use {{nextPosition}} - 1 as this could be a commit marker. > Fix StateRestoreListener To Use Correct Batch Ending Offset > ----------------------------------------------------------- > > Key: KAFKA-6367 > URL: https://issues.apache.org/jira/browse/KAFKA-6367 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.0, 1.0.0 > Reporter: Bill Bejeck > Assignee: Bill Bejeck > Priority: Major > Fix For: 1.0.2 > > > {{StateRestoreListener#restoreBatchCompleted}} takes the {{nextPosition}} > longĀ for the batch ending offset, but the {{nextPosition}} is not correct, it > should be the offset of the latest restored offset, but {{nextPosition}} is > the offset of the first not restored offset. > We can't automatically use {{nextPosition}} - 1 as this could be a commit > marker. -- This message was sent by Atlassian JIRA (v7.6.3#76005)