|
@@ -49,7 +49,7 @@ canal.instance.filter.black.regex=mysql\\.slave_.*
|
|
|
# mq config
|
|
# mq config
|
|
|
canal.mq.topic=example
|
|
canal.mq.topic=example
|
|
|
# dynamic topic route by schema or table regex
|
|
# dynamic topic route by schema or table regex
|
|
|
-#canal.mq.dynamicTopic=mytest1.user,mytest2\\..*,.*\\..*
|
|
|
|
|
|
|
+#canal.mq.dynamicTopic=mytest1.user,topic2:mytest2\\..*,.*\\..*
|
|
|
canal.mq.partition=0
|
|
canal.mq.partition=0
|
|
|
# hash partition config
|
|
# hash partition config
|
|
|
#canal.mq.enableDynamicQueuePartition=false
|
|
#canal.mq.enableDynamicQueuePartition=false
|
jianghang.loujh