From 2ead571a20ec036a2ab50854931e7edc5d0cd584 Mon Sep 17 00:00:00 2001 From: rewerma Date: Tue, 22 Jan 2019 11:51:55 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index 3457b98..cd01182 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/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的能力