jordanbull opened a new pull request, #12566: URL: https://github.com/apache/kafka/pull/12566
Only clear origOffsets when clearing the messageBatch. Prior to this change, origOffsets is cleared at the start of each convertMessages call in which all newly polled messages are added to origOffsets. In cases where RetriableException is thrown in SinkTask.put, polling is paused and the existing messageBatch is kept. This behavior resulted in clearing all offset tracking on the next attempt despite still having messages being tried and thus never committed after eventually succeeding. Reported in [KAFKA-13927](https://issues.apache.org/jira/browse/KAFKA-13927) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
