chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Updated Canal Kafka RocketMQ QuickStart (markdown)

rewerma
2019-01-22 11:51:55 +08:00
parent faadbfa181
commit 2ead571a20
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Canal-Kafka-RocketMQ-QuickStart.md

@@ -116,12 +116,15 @@ canal.mq.transaction = false
### canal.mq.dynamicTopic 表达式说明
canal 1.1.3版本之后, 支持配置格式：schema.table，多个配置之间使用逗号分隔
* 例子1：test\\\\.test 指定匹配的单表，发送到以 test\\\\.test为名字的topic上
canal 1.1.3版本之后, 支持配置格式：schema 或 schema.table，多个配置之间使用逗号分隔
* 例子1：test\\\\.test 指定匹配的单表，发送到以 test_test为名字的topic上
* 例子2：.\\\\..\* 匹配所有表，每个表都会发送到各自表名的topic上
* 例子3：test 指定匹配对应的库，一个库的所有表都会发送到库名的topic上
* 例子4：test\\\\.* 指定匹配的表达式，针对匹配的表会发送到各自表名的topic上
* 例子5：test,test1\\\\.test1，指定多个表达式，会将test库的表都发送到test的topic上，test1\\\\.test1的表发送到对应的test1\\\\.test1 topic上，其余的表发送到默认的canal.mq.topic值
* 例子5：test,test1\\\\.test1，指定多个表达式，会将test库的表都发送到test的topic上，test1\\\\.test1的表发送到对应的test1_test1 topic上，其余的表发送到默认的canal.mq.topic值
支持指定topic名称匹配：
* 例子：test:test,test1\\\\.test1;test2:test2,test3\\\\.test1 针对匹配的表会发送到指定的topic上
大家可以结合自己的业务需求，设置匹配规则，建议MQ开启自动创建topic的能力