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-23 23:08:06 +08:00
parent 0351cf187e
commit 62b21620ed
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Canal-Kafka-RocketMQ-QuickStart.md

@@ -65,7 +65,7 @@ canal.instance.global.spring.xml = classpath:spring/default-instance.xml
#### c. 修改mq配置文件`vi /usr/local/canal/conf/mq.yml`
```
#kafka 集群用,进行分隔: 192.168.1.117:9092,192.168.1.118:9092,192.168.1.119:9092
# kafka 集群用,进行分隔: 192.168.1.117:9092,192.168.1.118:9092,192.168.1.119:9092
servers: 192.168.1.117:9092
retries: 0
batchSize: 16384
@@ -116,12 +116,12 @@ vi logs/example/example.log
cd /usr/local/canal/
sh bin/stop.sh
```
### 3.7 使用canal.client 查看kafka topic中的代码样例
```
# // 可参考 canal kafka client 中的实现
com.alibaba.otter.canal.client.running.kafka.CanalKafkaClientExample
### 3.7 MQ数据消费
canal.client下有对应的MQ数据消费的样例工程,包含数据编解码的功能
* kafka模式: [com.alibaba.otter.canal.client.running.kafka.CanalKafkaClientExample](https://github.com/alibaba/canal/blob/master/client/src/test/java/com/alibaba/otter/canal/client/running/kafka/CanalKafkaClientExample.java)
* rocketMQ模式: [com.alibaba.otter.canal.client.running.rocketmq.CanalRocketMQClientExample](https://github.com/alibaba/canal/blob/master/client/src/test/java/com/alibaba/otter/canal/client/running/rocketmq/CanalRocketMQClientExample.java)
```
## 参考链接
[Canal QuickStart](https://github.com/alibaba/canal/wiki/QuickStart)
[Canal AdminGuide](https://github.com/alibaba/canal/wiki/AdminGuide)