From 607723fadb8823fa397195b7eeb84b526e1f19fa Mon Sep 17 00:00:00 2001 From: agapple Date: Mon, 25 Mar 2019 16:09:02 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index 7faf44c..12ce55e 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -179,5 +179,5 @@ sh bin/stop.sh ### 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) \ No newline at end of file +* kafka模式: [com.alibaba.otter.canal.example.kafka.CanalKafkaClientExample](https://github.com/alibaba/canal/blob/master/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientExample.java) +* rocketMQ模式: [com.alibaba.otter.canal.example.rocketmq.CanalRocketMQClientExample](https://github.com/alibaba/canal/blob/master/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java) \ No newline at end of file