Skip to content

Commit

Permalink
added trim() to topic name to ensure the topic name matches the index…
Browse files Browse the repository at this point in the history
… name
  • Loading branch information
ravib777 committed May 3, 2024
1 parent 6879f4b commit ffa8355
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
}
Expand Down

0 comments on commit ffa8355

Please sign in to comment.