1。kafka的安装： 略

2.cannal  配置 使用卡夫卡：

修改  /home/admin/canal-server/conf/canal.properties

2.1 修改canal.serverMode = kafka

2.2  修改MQ 的ip 端口  （修改为自己安装kafka 的IP）

3. 修改 instance (如：milestone)

cd /milstone

vi    instance.properties

topic 修改自定义的名字

4. java 监听这个topic  就可以收到消息了