[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bill Bejeck updated KAFKA-6367: ------------------------------- Summary: Fix StateRestoreListener To Use Correct Batch Ending Offset (was: Fix StateRestoreListener To Use Correct Ending Offset) > 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 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)