mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Canal Kafka RocketMQ QuickStart (markdown)
@@ -49,7 +49,7 @@ canal.instance.dbPassword = canal
|
||||
# mq config
|
||||
canal.mq.topic=example
|
||||
# 针对库名或者表名发送动态topic, 表达式如果只有库名则匹配库名的数据都会发送到对应名称topic
|
||||
# 如果是库名.表名则会发送到以库名.表名为名称的topic
|
||||
# 如果是库名.表名则匹配的数据会发送到以库名.表名为名称的topic
|
||||
#canal.mq.dynamicTopic=mytest,.*,mytest.user,mytest\\..*,.*\\..*
|
||||
canal.mq.partition=0
|
||||
# hash partition config
|
||||
|
||||
Reference in New Issue
Block a user