From 1bfcf20ea3a7acbdb1f5d58b1a240fc2d2cce2de Mon Sep 17 00:00:00 2001 From: rewerma Date: Fri, 28 Dec 2018 16:14:27 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index 768cebf..8914649 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -48,6 +48,9 @@ canal.instance.dbPassword = canal ... # mq config canal.mq.topic=example +# 针对库名或者表名发送动态topic, 表达式如果只有库名则匹配库名的数据都会发送到对应名称topic +# 如果是库名.表名则会发送到以库名.表名为名称的topic +#canal.mq.dynamicTopic=mytest,.*,mytest.user,mytest\\..*,.*\\..* canal.mq.partition=0 # hash partition config #canal.mq.partitionsNum=3