chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1544 from finefuture/MQ-fix-pr

Browse Source 
fix issue 1532
This commit is contained in:
agapple
2019-02-28 10:32:41 +08:00
committed by GitHub
parent f2368e5469 fd4c8db92b
commit 5e2eabb3c2
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java
View File

@@ -499,7 +499,7 @@ public class MQMessageUtils {
topics.add(topic); topics.add(topic);
} }
} else if (matchDynamicTopic(name, item)) { } else if (matchDynamicTopic(name, item)) {
topics.add(name); topics.add(name.toLowerCase());
} }
} }
return topics.isEmpty() ? null : topics; return topics.isEmpty() ? null : topics;