开发者社区 问答 正文

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

展开
收起
Java工程师 2023-05-08 19:20:36 139 发布于北京 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • kafka数据投递传输的是数据包哦,收到数据后还要解包成对应的message,可参考client中的kafka实现

    原回答者GitHub用户rewerma

    2023-05-09 19:46:57 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等