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)

agapple
2018-10-28 21:09:08 +08:00
parent de51818469
commit e70e098c6c
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Canal-Kafka-RocketMQ-QuickStart.md

@@ -16,7 +16,7 @@ canal 1.1.1版本之后, 默认支持将canal server接收到的binlog数据直
## 二、安装MQ ## 二、安装MQ
* Kafka安装参考：[Kafka QuickStart](https://github.com/alibaba/canal/wiki/Kafka-QuickStart) * Kafka安装参考：[Kafka QuickStart](https://github.com/alibaba/canal/wiki/Kafka-QuickStart)
* RocketMQ安装参考：待补充 * RocketMQ安装参考：[RocketMQ QuickStart](https://rocketmq.apache.org/docs/quick-start)
## 三、 安装canal.server ## 三、 安装canal.server
@@ -51,21 +51,15 @@ canal.instance.dbPassword = canal
``` ```
对应ip 地址的MySQL 数据库需进行相关初始化与设置, 可参考 [Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart) 对应ip 地址的MySQL 数据库需进行相关初始化与设置, 可参考 [Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart)
#### b. 修改canal 配置文件`vi /usr/local/canal/conf/canal.properties ` #### b. 修改canal 配置文件`vi /usr/local/canal/conf/canal.properties `
``` ```
# ... # ...
canal.ip=
canal.withoutNetty = true canal.withoutNetty = true
# tcp, kafka, RocketMQ # 可选项: tcp(默认), kafka, RocketMQ
canal.serverMode = kafka canal.serverMode = kafka
# zk server地址
canal.zkServers= 192.168.1.110:2181
canal.destinations= example
# ... # ...
canal.instance.global.spring.xml = classpath:spring/default-instance.xml
``` ```
详细参数可参考[Canal AdminGuide](https://github.com/alibaba/canal/wiki/AdminGuide) 其他详细参数可参考[Canal AdminGuide](https://github.com/alibaba/canal/wiki/AdminGuide)
#### c. 修改mq配置文件`vi /usr/local/canal/conf/mq.yml` #### c. 修改mq配置文件`vi /usr/local/canal/conf/mq.yml`