From 9bf719201267b96c1978723e2ab02cee6da89441 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Mon, 27 Apr 2020 10:05:44 -0700 Subject: [PATCH] MINOR: Fix typos in test mm2 config --- .../kafka/connect/mirror/MirrorConnectorsIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);