diff --git a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java index 8a15ad55c6b77..7e0e8835f0e0f 100644 --- a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java +++ b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java @@ -86,8 +86,8 @@ public void setup() throws InterruptedException { mm2Props.put("heartbeats.topic.replication.factor", "1"); mm2Props.put("offset-syncs.topic.replication.factor", "1"); mm2Props.put("config.storage.topic.replication.factor", "1"); - mm2Props.put("offset.stoage.topic.replication.factor", "1"); - mm2Props.put("status.stoage.topic.replication.factor", "1"); + mm2Props.put("offset.storage.topic.replication.factor", "1"); + mm2Props.put("status.storage.topic.replication.factor", "1"); mm2Props.put("replication.factor", "1"); mm2Config = new MirrorMakerConfig(mm2Props);