You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by kk...@apache.org on 2020/04/28 06:17:04 UTC

[kafka] branch 2.4 updated: MINOR: Fix typos in config properties in MM2 test (#8561)

This is an automated email from the ASF dual-hosted git repository.

kkarantasis pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.4 by this push:
     new ecbea14  MINOR: Fix typos in config properties in MM2 test (#8561)
ecbea14 is described below

commit ecbea1455ee9ef143b9f9ac316c76b243d82199e
Author: Jeff Widman <je...@jeffwidman.com>
AuthorDate: Mon Apr 27 23:10:08 2020 -0700

    MINOR: Fix typos in config properties in MM2 test (#8561)
    
    Fixed typos in two MM2 configs that define the replication factor for internal Connect topics.
    Only a single test was affected.
    
    Reviewers: Ryanne Dolan <ry...@gmail.com>, Konstantine Karantasis <ko...@confluent.io>
---
 .../apache/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 8b1bac9..aacf42b 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 class MirrorConnectorsIntegrationTest {
         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);