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> initMetaMap(Map taskCon topicMeta.put(SOURCE, meta); } - metaMap.put(topic, topicMeta); + metaMap.put(topic.trim(), topicMeta); idx += 1; } }