fixed dymaic topic

deployer/src/main/resources/canal.properties

@@ -111,4 +111,4 @@ canal.mq.canalBatchSize = 50
 canal.mq.canalGetTimeout = 100
 canal.mq.flatMessage = true
 canal.mq.compressionType = none
-canal.mq.acks = all
+canal.mq.acks = all

deployer/src/main/resources/example/instance.properties

@@ -45,7 +45,7 @@ canal.instance.filter.black.regex=
 
 # mq config
 canal.mq.topic=example
-# 动态topic, 需mq支持动态创建topic
+# dynamic topic route by table regex
 #canal.mq.dynamicTopic=.*,mytest\\..*,mytest2.user
 canal.mq.partition=0
 # hash partition config

instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalMQConfig.java

@@ -6,7 +6,7 @@ public class CanalMQConfig {
     private Integer partition;
     private Integer partitionsNum;
     private String  partitionHash;
-    private String dynamicTopic;
+    private String  dynamicTopic;
 
     public String getTopic() {
         return topic;