canal.kafka输出乱码
CentOS Linux release 7.3.1611 (Core) 3.10.0-514.el7.x86_64 JDK：jdk-8u161-linux-x64.tar.gz zookeeper：zookeeper-3.4.13.tar.gz kafka：kafka_2.11-2.0.0.tgz canal.kafka：canal.kafka-1.1.0.tar.gz MySQL：5.7.22-log 按照https://github.com/alibaba/canal/wiki/Canal-Kafka-QuickStart配置 kafka中全是乱码 请问需要在那里调整
bin/kafka-console-consumer.sh --bootstrap-server 192.168.10.110:9092 --topic example D mysql-binlog.000012 UTF-80BJP 401663 ? mysql-binlog.000012 UTF-80BJPH
mysql-binlog.000012 UTF-80B testJ tP+X b -+C-+++ 1 Pb? id (0B 1Ri++(11)
+e+ (0B 1R +a_cha(255) D +y_-+-bi++-g.000012 UTF-80,8 BJP 401877 ? +y_-+-bi++-g.000012 UTF-80,8 BJPI >
+y_-+-bi++-g.000012 *UTF-80,8 Beca_dJ +c+a___ca_d__e-+e+_+-gPTX b _-+_C-+++ 1 Pb
原提问者GitHub用户ddonline
写回答
-
kafka数据投递传输的是数据包哦，收到数据后还要解包成对应的message，可参考client中的kafka实现
原回答者GitHub用户rewerma
2023-05-09 19:46:57赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
