Skip to content

Commit 7c108cc

Browse files
authored
Merge pull request #432 from ravib777/trim_index_space
added trim to topic names to remove leading whitespace if exists
2 parents 8c5d933 + ffa8355 commit 7c108cc

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)