hutchiko opened a new pull request #11283: URL: https://github.com/apache/kafka/pull/11283
When using EOS checkpointed offsets are not updated to the latest offsets from the changelog because the `maybeWriteCheckpoint` method is only ever called when `commitNeeded=false`. This change will force the update if `enforceCheckpoint=true` . I have also added a test which verifies that both the state store and the checkpoint file are completely up to date with the changelog after the app has shutdown. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
