[GitHub] [kafka] mimaison commented on a change in pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

mimaison commented on a change in pull request #7577: URL: https://github.com/apache/kafka/pull/7577#discussion_r445443084 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java ## @@ -42,6 +47,7 @@ private static final

[GitHub] [kafka] mimaison commented on a change in pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

mimaison commented on a change in pull request #7577: URL: https://github.com/apache/kafka/pull/7577#discussion_r435196589 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java ## @@ -188,4 +219,101 @@ public void

[GitHub] [kafka] mimaison commented on a change in pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

mimaison commented on a change in pull request #7577: URL: https://github.com/apache/kafka/pull/7577#discussion_r435134966 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java ## @@ -16,6 +16,13 @@ */ package