You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2020/05/21 18:06:01 UTC
[kafka] branch 2.4 updated: MINOR: Correct MirrorMaker2 integration
test configs for Connect internal topics (#8653)
This is an automated email from the ASF dual-hosted git repository.
rhauch 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 76ccc1d MINOR: Correct MirrorMaker2 integration test configs for Connect internal topics (#8653)
76ccc1d is described below
commit 76ccc1dac186830191d75ce767c8867bd247e109
Author: Randall Hauch <rh...@gmail.com>
AuthorDate: Thu May 21 10:56:04 2020 -0500
MINOR: Correct MirrorMaker2 integration test configs for Connect internal topics (#8653)
The replication factor for the Connect workers’ internal topics were incorrectly named and not actually used.
---
.../kafka/connect/mirror/MirrorConnectorsIntegrationTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 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 aacf42b..30924ef 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
@@ -85,9 +85,9 @@ public class MirrorConnectorsIntegrationTest {
mm2Props.put("checkpoints.topic.replication.factor", "1");
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.storage.topic.replication.factor", "1");
- mm2Props.put("status.storage.topic.replication.factor", "1");
+ mm2Props.put("config.storage.replication.factor", "1");
+ mm2Props.put("offset.storage.replication.factor", "1");
+ mm2Props.put("status.storage.replication.factor", "1");
mm2Props.put("replication.factor", "1");
mm2Config = new MirrorMakerConfig(mm2Props);