这是正常的吧 一个是读取数据库数据 一个是读日志变化的数据  

0 0

但是如果是用binlog读到kafka，value的数据格式就不同了，在这种情况下应该如何正确读取这里面的数据呢

0 0

比如用mysqlreader读到kafka，数据的格式和examples文件夹里的kafka_stream_data.txt是一样的

0 0

  用的就是官网文档上binlog-source和mysql-source这两个插件，然后插到kafka不同的topic，看在kafka里面的数据做的比较  

0 0

  binlog-source 和mysql-source是什么插件 用的chunjun binlog插件采集到kafka和哪一个插件比较

• 想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：https://www.dtstack.com/?src=bbs

  
  

  同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：

  https://github.com/DTStack/chunjun

0 0