From 92e1c2aaa76ee99e85faba10111088115f240265 Mon Sep 17 00:00:00 2001 From: agapple Date: Fri, 28 Dec 2018 18:38:11 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index ecee309..bdb05e0 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -114,6 +114,8 @@ canal 1.1.3版本之后, 支持配置格式：schema.table，多个配置之间 * 例子4：test\\\\.* 指定匹配的表达式，针对匹配的表会发送到各自表名的topic上 * 例子5：test,test1\\\\.test1，指定多个表达式，会将test库的表都发送到test的topic上，test1\\\\.test1的表发送到对应的test1\\\\.test1 topic上，其余的表发送到默认的canal.mq.topic值 +大家可以结合自己的业务需求，设置匹配规则，建议MQ开启自动创建topic的能力 + ### canal.mq.partitionHash 表达式说明 canal 1.1.3版本之后, 支持配置格式：schema.table:pk1^pk2，多个配置之间使用逗号分隔