diff --git a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java index bc981647..163dcade 100644 --- a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java +++ b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java @@ -499,7 +499,7 @@ public class MQMessageUtils { topics.add(topic); } } else if (matchDynamicTopic(name, item)) { - topics.add(name); + topics.add(name.toLowerCase()); } } return topics.isEmpty() ? null : topics;