canal 结合 kafka 入门

1。kafka的安装： 略

 

SRE实战 互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。

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  就可以收到消息了

 

扫码关注我们

微信号：SRE实战

拒绝背锅 运筹帷幄