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