diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index b4e1b3c..9e9b432 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -16,7 +16,7 @@ canal 1.1.1版本之后, 默认支持将canal server接收到的binlog数据直 ## 二、安装MQ * Kafka安装参考:[Kafka QuickStart](https://github.com/alibaba/canal/wiki/Kafka-QuickStart) -* RocketMQ安装参考:待补充 +* RocketMQ安装参考:[RocketMQ QuickStart](https://rocketmq.apache.org/docs/quick-start) ## 三、 安装canal.server @@ -51,21 +51,15 @@ canal.instance.dbPassword = canal ``` 对应ip 地址的MySQL 数据库需进行相关初始化与设置, 可参考 [Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart) - #### b. 修改canal 配置文件`vi /usr/local/canal/conf/canal.properties ` ``` # ... -canal.ip= canal.withoutNetty = true -# tcp, kafka, RocketMQ +# 可选项: tcp(默认), kafka, RocketMQ 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`