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)

agapple
2020-08-21 15:05:29 +08:00
parent 590357cd79
commit f3b55bebbc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Canal-Kafka-RocketMQ-QuickStart.md

@@ -127,14 +127,14 @@ canal 1.1.3版本之后, 支持配置格式：schema 或 schema.table，多个
* 例子1：test\\\\.test 指定匹配的单表，发送到以test_test为名字的topic上
* 例子2：.*\\\\..\* 匹配所有表，则每个表都会发送到各自表名的topic上
* 例子3：test 指定匹配对应的库，一个库的所有表都会发送到库名的topic上
* 例子4：test\\\\.* 指定匹配的表达式，针对匹配的表会发送到各自表名的topic上
* 例子4：test\\\\..* 指定匹配的表达式，针对匹配的表会发送到各自表名的topic上
* 例子5：test,test1\\\\.test1，指定多个表达式，会将test库的表都发送到test的topic上，test1\\\\.test1的表发送到对应的test1_test1 topic上，其余的表发送到默认的canal.mq.topic值
为满足更大的灵活性，允许对匹配条件的规则指定发送的topic名字，配置格式：topicName:schema 或 topicName:schema.table
* 例子1: test:test\\\\.test 指定匹配的单表，发送到以test为名字的topic上
* 例子2: test:.*\\\\..\* 匹配所有表，因为有指定topic，则每个表都会发送到test的topic下
* 例子3: test:test 指定匹配对应的库，一个库的所有表都会发送到test的topic下
* 例子4：testA:test\\\\.* 指定匹配的表达式，针对匹配的表会发送到testA的topic下
* 例子4：testA:test\\\\..* 指定匹配的表达式，针对匹配的表会发送到testA的topic下
* 例子5：test0:test,test1:test1\\\\.test1，指定多个表达式，会将test库的表都发送到test0的topic下，test1\\\\.test1的表发送到对应的test1的topic下，其余的表发送到默认的canal.mq.topic值
大家可以结合自己的业务需求，设置匹配规则，建议MQ开启自动创建topic的能力