kumarlokesh opened a new pull request, #19874: URL: https://github.com/apache/kafka/pull/19874
Fixes https://issues.apache.org/jira/browse/KAFKA-18995 - This PR adds a check in the `syncGroupOffset` method that compares the converted offset from the source cluster with the existing checkpoint in the target cluster's checkpoint store. - If the existing checkpoint has a higher downstream offset, we skip syncing the lower converted offset. -- 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
