C0urante opened a new pull request, #14567: URL: https://github.com/apache/kafka/pull/14567
[Jira](https://issues.apache.org/jira/browse/KAFKA-13988) Based off of https://github.com/apache/kafka/pull/13905, which itself appears to be based off of https://github.com/apache/kafka/pull/12358. The only changes applied here are the ones proposed during review of https://github.com/apache/kafka/pull/13905. This PR tweaks how the `MirrorSourceTask` class interacts with its consumer on startup. With this change, instead of manually seeking to offset 0 when no committed offset for a topic partition is found, no seek is performed at all. This allows users to configure MM2 to begin replicating from the ends of topics (as opposed to the beginning, which is and remains the default behavior) by configuring its consumer with `auto.offset.reset` set to `latest`. ### 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
