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