From fd4c8db92b10b9da15a362102b2056b9bfab668f Mon Sep 17 00:00:00 2001
From: TomlongTK <1120170646@qq.com>
Date: Tue, 26 Feb 2019 14:23:29 +0800
Subject: [PATCH] fix issue 1532
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

因为binlog日志同表名大小写的原因导致kafka的日志恢复并resize，报错之后引起集群崩溃
现在修改为投递消息的topic不区分表名大小写
---
 .../java/com/alibaba/otter/canal/common/MQMessageUtils.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;