在mysql数据库中插入一条记录后，用命令bin/kafka-console-consumer.sh --zookeeper 192.168.206.128:2181 --topic canal1 --from-beginning，看到消费端输出乱码： * : mysql-bin.000027 *UTF-80BJP 229 * 7 mysql-bin.000027 *UTF-80BJPF mysql-bin.000027 *UTF-80B can_dbJ user_testP+X b -+C-+++ 1 Pb id ( 0B 6Ri++(11) +a+e ( 0B dafdR +a_cha(40) age ( 0B 15Ri++(11) : +y_-+-bi+.000027 *UTF-80,8 BJP 261 * 7 +y_-+-bi+.000027 *UTF-80,8 BJPF +y_-+-bi+.000027 UTF-80,8 B ca+dbJ +e+e_+PX b -+C-+++ 1 Pb^ id ( 0B 7Ri++(11) +a+e ( 0B eeeR +a_cha(40) age ( 0B 11Ri++(11) : +y-+-bi+.000027 *UTF-80,8 BJP 262 然后看了kafka-client中的代码，改了AbstractKafkaTest.java相应的配置参数，如 public static String topic = "canal1"; public static Integer partition = 0; public static String groupId = ""; public static String servers = "192.168.206.128:6667"; public static String zkServers = "192.168.206.128:2181"; 后，当往mysql中插入新记录后，但运行KafkaClientRunningTest.java没有收到数据包。各位有没有遇到过这种情况。
原提问者GitHub用户brightsong
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
canal kafka 模式默认是发送Message对象的序列化字节不是可见字符串,client接收到会反序列化. 如要发送可见字符串,请用 flatMessage模式,将会发送json格式数据
原回答者GitHub用户rewerma
评论
全部评论 (0)