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
2019-04-04 14:11:42 +08:00
parent 4a48af70a5
commit 0993736054
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Canal-Kafka-RocketMQ-QuickStart.md

@@ -113,14 +113,14 @@ canal.mq.transaction = false
canal 1.1.3版本之后, 支持配置格式：schema 或 schema.table，多个配置之间使用逗号或分号分隔
* 例子1：test\\\\.test 指定匹配的单表，发送到以test_test为名字的topic上
* 例子2：.\\\\..\* 匹配所有表，则每个表都会发送到各自表名的topic上
* 例子2：.*\\\\..\* 匹配所有表，则每个表都会发送到各自表名的topic上
* 例子3：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下
* 例子2: test:.*\\\\..\* 匹配所有表，因为有指定topic，则每个表都会发送到test的topic下
* 例子3: test:test 指定匹配对应的库，一个库的所有表都会发送到test的topic下
* 例子4：testA:test\\\\.* 指定匹配的表达式，针对匹配的表会发送到testA的topic下
* 例子5：test0:test,test1:test1\\\\.test1，指定多个表达式，会将test库的表都发送到test0的topic下，test1\\\\.test1的表发送到对应的test1的topic下，其余的表发送到默认的canal.mq.topic值
@@ -131,10 +131,10 @@ canal 1.1.3版本之后, 支持配置格式：schema 或 schema.table，多个
canal 1.1.3版本之后, 支持配置格式：schema.table:pk1^pk2，多个配置之间使用逗号分隔
* 例子1：test\\\\.test:pk1^pk2 指定匹配的单表，对应的hash字段为pk1 + pk2
* 例子2：.\\\\..\*:id 正则匹配，指定所有正则匹配的表对应的hash字段为id
* 例子3：.\\\\..\*:$pk$ 正则匹配，指定所有正则匹配的表对应的hash字段为表主键(自动查找)
* 例子2：.*\\\\..\*:id 正则匹配，指定所有正则匹配的表对应的hash字段为id
* 例子3：.*\\\\..\*:$pk$ 正则匹配，指定所有正则匹配的表对应的hash字段为表主键(自动查找)
* 例子4: 匹配规则啥都不写，则默认发到0这个partition上
* 例子5：.\\\\..\* ，不指定pk信息的正则匹配，将所有正则匹配的表,对应的hash字段为表名
* 例子5：.*\\\\..\* ，不指定pk信息的正则匹配，将所有正则匹配的表,对应的hash字段为表名
* 按表hash: 一张表的所有数据可以发到同一个分区，不同表之间会做散列 (会有热点表分区过大问题)
* 例子6: test\\\\.test:id,.\\\\..\* , 针对test的表按照id散列,其余的表按照table散列