Justinwins opened a new pull request, #12358: URL: https://github.com/apache/kafka/pull/12358
see https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-13988?filter=allopenissues I bumped into the same issue in production env, and i worked around in this way (as PR ). With `topicPartitionOffsets.forEach(consumer::seek);`, mm2 seeks all topic partitions even though there have been no commits in mm2-offset topic .For example, if A-0 is a topic parition in source target , and mm2 has never synced it before; then mm2 will seek to 0 for A-0, and sync from 0 . ### 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
