Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6367

Fix StateRestoreListener To Use Correct Batch Ending Offset

    XMLWordPrintableJSON

    Details

    • 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
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                bbejeck Bill Bejeck
                Reporter:
                bbejeck Bill Bejeck
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: