[solr-sandbox] branch main updated: Producer uses first topic name if it's a list

[ma...@apache.org]

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

markrmiller pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git


The following commit(s) were added to refs/heads/main by this push:
     new 50ec3c2  Producer uses first topic name if it's a list
50ec3c2 is described below

commit 50ec3c20c70c200d80a6e9137ab71b716367051a
Author: markrmiller <ma...@apache.org>
AuthorDate: Fri Aug 11 14:34:28 2023 -0500

    Producer uses first topic name if it's a list
---
 .../main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
index 8dddfc0..728d116 100644
--- a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
+++ b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
@@ -56,7 +56,7 @@ public class KafkaMirroringSink implements RequestMirroringSink, Closeable {
         // Create Producer record
         try {
 
-            producer.send(new ProducerRecord<>(conf.get(KafkaCrossDcConf.TOPIC_NAME), request), (metadata, exception) -> {
+            producer.send(new ProducerRecord<>(conf.get(KafkaCrossDcConf.TOPIC_NAME).split(",")[0], request), (metadata, exception) -> {
                 if (exception != null) {
                     log.error("Failed adding update to CrossDC queue! request=" + request.getSolrRequest(), exception);
                 }