mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Canal Kafka RocketMQ QuickStart (markdown)
@@ -114,6 +114,8 @@ canal 1.1.3版本之后, 支持配置格式:schema.table,多个配置之间
|
||||
* 例子4:test\\\\.* 指定匹配的表达式,针对匹配的表会发送到各自表名的topic上
|
||||
* 例子5:test,test1\\\\.test1,指定多个表达式,会将test库的表都发送到test的topic上,test1\\\\.test1的表发送到对应的test1\\\\.test1 topic上,其余的表发送到默认的canal.mq.topic值
|
||||
|
||||
大家可以结合自己的业务需求,设置匹配规则,建议MQ开启自动创建topic的能力
|
||||
|
||||
### canal.mq.partitionHash 表达式说明
|
||||
|
||||
canal 1.1.3版本之后, 支持配置格式:schema.table:pk1^pk2,多个配置之间使用逗号分隔
|
||||
|
||||
Reference in New Issue
Block a user