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 17:29:34 UTC
[kafka] branch 2.5 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.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.5 by this push:
new 003c9d5 MINOR: Correct MirrorMaker2 integration test configs for Connect internal topics (#8653)
003c9d5 is described below
commit 003c9d50d6823a1f0b91b9f071b3afb74ae04da2
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 7e0e883..916c008 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);