From 09937360546e38b28a0ef2251fbe9f3d2499f3b8 Mon Sep 17 00:00:00 2001 From: agapple Date: Thu, 4 Apr 2019 14:11:42 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index f13ab60..a9185df 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/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散列