[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ewen Cheslack-Postava updated KAFKA-6367: ----------------------------------------- Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to 1.0.2 as this isn't ready for 1.0.1. > Fix StateRestoreListener To Use Correct 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)