From 14ba358525068163ea462f5c490aff24677fa23d Mon Sep 17 00:00:00 2001
From: agapple <jianghang115@gmail.com>
Date: Fri, 28 Dec 2018 18:35:50 +0800
Subject: [PATCH] fixed dymaic topic

---
 deployer/src/main/resources/canal.properties                    | 2 +-
 deployer/src/main/resources/example/instance.properties         | 2 +-
 .../com/alibaba/otter/canal/instance/core/CanalMQConfig.java    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/deployer/src/main/resources/canal.properties b/deployer/src/main/resources/canal.properties
index 5d7b9d06..42fd373d 100644
--- a/deployer/src/main/resources/canal.properties
+++ b/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
\ No newline at end of file
diff --git a/deployer/src/main/resources/example/instance.properties b/deployer/src/main/resources/example/instance.properties
index 6a8f045a..30eb8b9e 100644
--- a/deployer/src/main/resources/example/instance.properties
+++ b/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
diff --git a/instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalMQConfig.java b/instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalMQConfig.java
index 193307eb..3d49f0fa 100644
--- a/instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalMQConfig.java
+++ b/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;