Skip to content

Commit ffa8355

Browse files
committed
added trim() to topic name to ensure the topic name matches the index name
1 parent 6879f4b commit ffa8355

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/splunk/kafka/connect/SplunkSinkConnectorConfig.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -527,7 +527,7 @@ private Map<String, Map<String, String>> initMetaMap(Map<String, String> taskCon
527527
topicMeta.put(SOURCE, meta);
528528
}
529529

530-
metaMap.put(topic, topicMeta);
530+
metaMap.put(topic.trim(), topicMeta);
531531
idx += 1;
532532
}
533533
}

0 commit comments

Comments
 (0)