diff --git a/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java b/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java index e13873e2633e4..7ac68319bca6f 100644 --- a/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java +++ b/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java @@ -235,7 +235,7 @@ private void addHerder(SourceAndTarget sourceAndTarget) { DistributedConfig distributedConfig = new DistributedConfig(workerProps); String kafkaClusterId = ConnectUtils.lookupKafkaClusterId(distributedConfig); // Create the admin client to be shared by all backing stores for this herder - Map adminProps = new HashMap<>(config.originals()); + Map adminProps = new HashMap<>(distributedConfig.originals()); ConnectUtils.addMetricsContextProperties(adminProps, distributedConfig, kafkaClusterId); SharedTopicAdmin sharedAdmin = new SharedTopicAdmin(adminProps); KafkaOffsetBackingStore offsetBackingStore = new KafkaOffsetBackingStore(sharedAdmin);