mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1022018101
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java:
##
@@ -77,20 +79,23 @@ public void testReplicationConfigProperties() {
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1021676801
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java:
##
@@ -16,23 +16,37 @@
*/
package org.apache.kafka.connect.mirror;
+import org.a
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1012087744
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:
##
@@ -0,0 +1,553 @@
+/*
+ *
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1008070254
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:
##
@@ -0,0 +1,553 @@
+/*
+ *
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1007859820
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java:
##
@@ -82,15 +84,17 @@ public void testClientConfigProperties() {
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r1007096564
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/clients/admin/FakeForwardingAdminWithLocalMetadata.java:
##
@@ -0,0 +1,117 @@
+package org.apache.kafka
mimaison commented on code in PR #12577:
URL: https://github.com/apache/kafka/pull/12577#discussion_r994551128
##
clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or