You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ma...@apache.org on 2022/09/14 22:55:01 UTC
[solr-sandbox] branch crossdc-wip updated: Improve test to cover a bit more. (#41)
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch crossdc-wip
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git
The following commit(s) were added to refs/heads/crossdc-wip by this push:
new 5214d5c Improve test to cover a bit more. (#41)
5214d5c is described below
commit 5214d5cadc5487f22f16132cd4c5f2106fa44161
Author: Mark Robert Miller <ma...@apache.org>
AuthorDate: Wed Sep 14 17:54:55 2022 -0500
Improve test to cover a bit more. (#41)
---
.../src/test/java/org/apache/solr/crossdc/ZkConfigIntegrationTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/crossdc-producer/src/test/java/org/apache/solr/crossdc/ZkConfigIntegrationTest.java b/crossdc-producer/src/test/java/org/apache/solr/crossdc/ZkConfigIntegrationTest.java
index d1979e1..bcb28c2 100644
--- a/crossdc-producer/src/test/java/org/apache/solr/crossdc/ZkConfigIntegrationTest.java
+++ b/crossdc-producer/src/test/java/org/apache/solr/crossdc/ZkConfigIntegrationTest.java
@@ -116,7 +116,7 @@ import java.util.Properties;
Map<String, Object> properties = new HashMap<>();
properties.put(KafkaCrossDcConf.ZK_CONNECT_STRING, solrCluster2.getZkServer().getZkAddress());
- properties.put(KafkaCrossDcConf.TOPIC_NAME, TOPIC);
+
consumer.start(properties);
}