[ https://issues.apache.org/jira/browse/KAFKA-13659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton resolved KAFKA-13659. ----------------------------------- Fix Version/s: 3.5.0 Resolution: Fixed > MM2 should read all offset syncs at start up > -------------------------------------------- > > Key: KAFKA-13659 > URL: https://issues.apache.org/jira/browse/KAFKA-13659 > Project: Kafka > Issue Type: Improvement > Components: mirrormaker > Reporter: Kanalas Vidor > Assignee: Greg Harris > Priority: Major > Fix For: 3.5.0 > > > MirrorCheckpointTask uses OffsetSyncStore, and does not check whether > OffsetSyncStore managed to read to the "end" of the offset-syncs topic. > OffsetSyncStore should fetch the endoffset of the topic at startup, and set a > flag when it finally reaches the endoffset in consumption. > MirrorCheckpointTask.poll should wait for this flag to be true before doing > any in-memory updates and group offset management. -- This message was sent by Atlassian Jira (v8.20.10#820010)