|
@@ -45,8 +45,8 @@ canal.instance.filter.black.regex=
|
|
|
|
|
|
|
|
# mq config
|
|
# mq config
|
|
|
canal.mq.topic=example
|
|
canal.mq.topic=example
|
|
|
-# dynamic topic route by table regex
|
|
|
|
|
-#canal.mq.dynamicTopic=.*,mytest\\..*,mytest2.user
|
|
|
|
|
|
|
+# dynamic topic route by schema or table regex
|
|
|
|
|
+#canal.mq.dynamicTopic=.*,mytest,mytest\\..*,mytest2.user
|
|
|
canal.mq.partition=0
|
|
canal.mq.partition=0
|
|
|
# hash partition config
|
|
# hash partition config
|
|
|
#canal.mq.partitionsNum=3
|
|
#canal.mq.partitionsNum=3
|
mcy