[KAFKA-6367] Fix StateRestoreListener To Use Correct Batch Ending Offset

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0, 1.0.0
• Fix Version/s: 1.0.1, 1.1.0
• Component/s: streams
• Assignee: Bill Bejeck
• Reporter: Bill Bejeck
• Created: 14/Dec/17 22:37
• Updated: 12/Feb/18 17:20
• Resolved: 07/Feb/18 19:24

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.

Issue Links

• links to: GitHub Pull Request #4507