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:10:33 +08:00
parent 62b21620ed
commit a761e21f37
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
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/rocketmq 集群配置: 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
@@ -95,7 +95,6 @@ retries: 对应kafka的`ProducerConfig.RETRIES_CONFIG`
batchSize: 对应kafka的`ProducerConfig.BATCH_SIZE_CONFIG`
lingerMs: 对应kafka的`ProducerConfig.LINGER_MS_CONFIG`
bufferMemory: 对应kafka的`ProducerConfig.BUFFER_MEMORY_CONFIG`
filterTransactionEntry: 过滤事务头、尾
```
### 3.4 启动
```
@@ -120,8 +119,4 @@ sh bin/stop.sh
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)
* 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)