diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index 6e9696a..ed8f5f5 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -49,7 +49,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