chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Updated Canal Kafka RocketMQ QuickStart (markdown)

rewerma
2019-01-14 14:34:29 +08:00
parent 6eda493fa1
commit 3d5bb3073b
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Canal-Kafka-RocketMQ-QuickStart.md

@@ -48,8 +48,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
@@ -60,6 +59,12 @@ canal.mq.partition=0
```
对应ip 地址的MySQL 数据库需进行相关初始化与设置, 可参考 [Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart)
dynamicTopic规则：
表达式如果只有库名则匹配库名的数据都会发送到对应名称topic, 如果是库名.表名则匹配的数据会发送到以'库名_表名'为名称的topic。如要指定topic名称，则可以配置：
```
canal.mq.dynamicTopic=examp2:.*;exmaple3:mytest\\..*,mytest2\\..*;example4:mytest3.user
```
以topic名 ':' 正则规则作为配置, 多个topic配置之间以 ';'隔开, message会发送到所有复合规则的topic
#### b. 修改canal 配置文件`vi /usr/local/canal/conf/canal.properties `
```