From ffa83551f22622114de4983401a25f982938801f Mon Sep 17 00:00:00 2001
From: ravib777 <rbhardwaj@confluent.io>
Date: Fri, 3 May 2024 13:33:47 +1000
Subject: [PATCH] added trim() to topic name to ensure the topic name matches
 the index name

---
 .../com/splunk/kafka/connect/SplunkSinkConnectorConfig.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/splunk/kafka/connect/SplunkSinkConnectorConfig.java b/src/main/java/com/splunk/kafka/connect/SplunkSinkConnectorConfig.java
index ea16b9d9..0859a825 100644
--- a/src/main/java/com/splunk/kafka/connect/SplunkSinkConnectorConfig.java
+++ b/src/main/java/com/splunk/kafka/connect/SplunkSinkConnectorConfig.java
@@ -527,7 +527,7 @@ private Map<String, Map<String, String>> initMetaMap(Map<String, String> taskCon
                     topicMeta.put(SOURCE, meta);
                 }
 
-                metaMap.put(topic, topicMeta);
+                metaMap.put(topic.trim(), topicMeta);
                 idx += 1;
             }
         }