diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index 9e64376..8e6c613 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -127,14 +127,14 @@ canal 1.1.3版本之后, 支持配置格式:schema 或 schema.table,多个 * 例子1:test\\\\.test 指定匹配的单表,发送到以test_test为名字的topic上 * 例子2:.*\\\\..\* 匹配所有表,则每个表都会发送到各自表名的topic上 * 例子3:test 指定匹配对应的库,一个库的所有表都会发送到库名的topic上 -* 例子4:test\\\\.* 指定匹配的表达式,针对匹配的表会发送到各自表名的topic上 +* 例子4:test\\\\..* 指定匹配的表达式,针对匹配的表会发送到各自表名的topic上 * 例子5:test,test1\\\\.test1,指定多个表达式,会将test库的表都发送到test的topic上,test1\\\\.test1的表发送到对应的test1_test1 topic上,其余的表发送到默认的canal.mq.topic值 为满足更大的灵活性,允许对匹配条件的规则指定发送的topic名字,配置格式:topicName:schema 或 topicName:schema.table * 例子1: test:test\\\\.test 指定匹配的单表,发送到以test为名字的topic上 * 例子2: test:.*\\\\..\* 匹配所有表,因为有指定topic,则每个表都会发送到test的topic下 * 例子3: test:test 指定匹配对应的库,一个库的所有表都会发送到test的topic下 -* 例子4:testA:test\\\\.* 指定匹配的表达式,针对匹配的表会发送到testA的topic下 +* 例子4:testA:test\\\\..* 指定匹配的表达式,针对匹配的表会发送到testA的topic下 * 例子5:test0:test,test1:test1\\\\.test1,指定多个表达式,会将test库的表都发送到test0的topic下,test1\\\\.test1的表发送到对应的test1的topic下,其余的表发送到默认的canal.mq.topic值 大家可以结合自己的业务需求,设置匹配规则,建议MQ开启自动创建topic的能力