mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Canal Kafka RocketMQ QuickStart (markdown)
@@ -63,7 +63,7 @@ canal.mq.partition=0
|
||||
dynamicTopic规则:
|
||||
表达式如果只有库名则匹配库名的数据都会发送到对应名称topic, 如果是库名.表名则匹配的数据会发送到以'库名_表名'为名称的topic。如要指定topic名称,则可以配置:
|
||||
```
|
||||
canal.mq.dynamicTopic=examp2:.*;exmaple3:mytest\\..*,mytest2\\..*;example4:mytest3.user
|
||||
canal.mq.dynamicTopic=example1:.*;exmaple2:mytest2\\..*;example3:mytest3.user
|
||||
```
|
||||
以topic名 ':' 正则规则作为配置, 多个topic配置之间以 ';'隔开, message会发送到所有符合规则的topic
|
||||
|
||||
|
||||
Reference in New Issue
Block a user