Merge pull request #1 from didiez/fix-topic-to-collection-name

fix jcustenborder#53 use topic name to compute collection name
didiez · Mar 29, 2023 · 31c57d9 · 31c57d9
2 parents c917b5c + 77a145b
commit 31c57d9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/solr/HttpSolrSinkTask.java b/src/main/java/com/github/jcustenborder/kafka/connect/solr/HttpSolrSinkTask.java
@@ -53,7 +53,8 @@ SolrClient client(String topic) {
   @Override
   protected void process(String topic, UpdateRequest updateRequest) throws IOException, SolrServerException {
     SolrClient client = client(topic);
-    UpdateResponse response = updateRequest.process(client);
+    String collection = topic.isBlank() ? null : topic;
+    UpdateResponse response = updateRequest.process(client, collection);
     log.trace("process() - qtime = {} elapsedTime = {}", response.getQTime(), response.getElapsedTime());
   }