From 3d5bb3073bf0bda8d714da2681e920c364b01dc9 Mon Sep 17 00:00:00 2001 From: rewerma Date: Mon, 14 Jan 2019 14:34:29 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index ed8f5f5..7145aa4 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -48,8 +48,7 @@ canal.instance.dbPassword = canal ... # mq config canal.mq.topic=example -# 针对库名或者表名发送动态topic, 表达式如果只有库名则匹配库名的数据都会发送到对应名称topic -# 如果是库名.表名则匹配的数据会发送到以库名_表名为名称的topic +# 针对库名或者表名发送动态topic #canal.mq.dynamicTopic=mytest,.*,mytest.user,mytest\\..*,.*\\..* canal.mq.partition=0 # hash partition config @@ -60,6 +59,12 @@ canal.mq.partition=0 ``` 对应ip 地址的MySQL 数据库需进行相关初始化与设置, 可参考 [Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart) +dynamicTopic规则: +表达式如果只有库名则匹配库名的数据都会发送到对应名称topic, 如果是库名.表名则匹配的数据会发送到以'库名_表名'为名称的topic。如要指定topic名称,则可以配置: +``` +canal.mq.dynamicTopic=examp2:.*;exmaple3:mytest\\..*,mytest2\\..*;example4:mytest3.user +``` +以topic名 ':' 正则规则作为配置, 多个topic配置之间以 ';'隔开, message会发送到所有复合规则的topic #### b. 修改canal 配置文件`vi /usr/local/canal/conf/canal.properties ` ```