|
@@ -49,6 +49,6 @@ canal.mq.topic=example
|
|
|
#canal.mq.dynamicTopic=.*,mytest,mytest\\..*,mytest2.user
|
|
|
canal.mq.partition=0
|
|
|
# hash partition config
|
|
|
-#canal.mq.partitionsNum=3
|
|
|
+#canal.mq.partitionsNum=4
|
|
|
#canal.mq.partitionHash=test.table:id^name,.*\\..*
|
|
|
#################################################
|