AI 助理
备案控制台
开发者社区 问答 正文

消息队列Kafka版连接报错This message has failed its CRC c...

已解决

消息队列Kafka版连接报错This message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt

展开
收起
提个问题 2024-05-30 10:02:02 612 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 社区答人
    开发者社区问答官方账号
    官方回答
    采纳回答
    kafka-clients 3.0版本开始，客户端默认会开启事务。由于云存储topic不支持事务，所以会报这个错误。
    三种解决方案：
    1.降低 客户端版本为3.0以下。
    2.topic 存储引擎由云存储更换为local存储引擎。
    3.设置enable.idempotence为false。
    详情参考存储引擎对比。
    2024-05-30 10:02:03
    赞同 展开评论
问答分类：
消息中间件 Kafka 云消息队列 Kafka 版
问答标签：
云消息队列 Kafka 版报错 云消息队列 Kafka 版连接 消息队列连接 消息队列报错 云消息队列 Kafka 版message
问答地址：
开发者社区 > 微服务 > 问答
相关问答
在Flink CDC中flink版本1.15，写入kafka报错，如何解决？
96
1
0
消息队列RocketMQ版用rocketmq-console连接不上
119
1
0
微消息队列mqtt如何使用websocket协议连接
131
1
0
如何使用Python连接Kafka？
104
1
0
云消息队列 RabbitMQ 版是否支持公网连接？
65
1
0
在Flink CDC中，用pipeline 连接器 同步mysql数据到kafka报错了，缺少什么？
143
1
0
数据集成kafka报错empty ConsumerRecords and stopWhenPo...
71
1
0
消息队列Kafka版连接报错GroupAuthorizationException
268
1
0
使用SDK连接消息队列Kafka版实例该使用什么版本号
91
1
0
消息队列Kafka发消息报错CORRUPT_MESSAGE
478
1
0