diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md
index 9813996..bbd2e26 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 集群用,进行分隔: 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)