From a761e21f37de2ab903e721ce11504cf64760d6b3 Mon Sep 17 00:00:00 2001 From: agapple Date: Tue, 23 Oct 2018 23:10:33 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index bbd2e26..125f2aa 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/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) \ No newline at end of file