【kafka】kafka record is corrupt（记录损坏）

àì夳堔傛蜴生んèń 2022-08-30 11:46 201阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70]

# 1.概述 #

转载：[kafka消费者无法消费异常][kafka]

我忘记我为啥遇到这个问题了，转载一下

今天被一个kafka消费异常折磨了一天，头差点炸了，还好最后解决了它

异常：服务器：record is corrupt（记录损坏）不明原因 有可能磁盘空间不足导致 导致消费者无法正常消费消息 卡在某一个offset 不能继续消费

解决办法：先停掉消费者程序 杀掉进程（不可关闭kafka服务）然后手动设置偏移量 跳过卡在的offset位置

进入kafka目录，命令：

`bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --group groupName --reset-offsets --to-offset 1000 --topic topicName --execute`

然后重启消费者程序 ok

该问题和 [【Kafka】Kafka Record for partition topic at offset xx is invalid, cause: Record corrupt][Kafka_Kafka Record for partition topic at offset xx is invalid_ cause_ Record corrupt] 重复问题。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70]: /images/20220829/5387668107dd4cf5a00c9a8abaa16b32.png
[kafka]: https://blog.csdn.net/qq_37751844/article/details/103879332
[Kafka_Kafka Record for partition topic at offset xx is invalid_ cause_ Record corrupt]: https://blog.csdn.net/qq_21383435/article/details/108622095

发表评论取消回复

表情：

评论列表（有 0 条评论，201人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java记录（Record）

什么是Record？一个专门用于描述内容不可变的，记录数据的类它可以自动生成对定义数据进行创建、设置、访问、比较等代码，所以也被称作“数据类”。记录类

小灰灰/ 2024年03月26日 13:43/ 0 赞/ 117 阅读

相关【java】record类记录类

[https://www.liaoxuefeng.com/wiki/1252599548343744/1331429187256353][https_www.liaoxuefe

比眉伴天荒/ 2024年03月26日 13:28/ 0 赞/ 78 阅读

相关解决xlrd.biffh.XLRDError: Unsupported format, or corrupt file: Expected BOF record； found b‘Debug is

目录解决xlrd.biffh.XLRDError: Unsupported format, or corrupt file: Expected BOF record; fo

你的名字/ 2024年02月21日 09:00/ 0 赞/ 30 阅读

相关【.NET Core】记录（Record）详解

【.NET Core】记录（Record）详解文章目录【.NET Core】记录（Record）详解一、什么是记录二、定义一

我不是女神ヾ/ 2024年02月05日 21:58/ 0 赞/ 25 阅读

相关同义词与 Record is locked by another user

问题一登录systemHR下的表：system用户下查询【select t.\ from test1】弹窗：ORA-00942:表或视图不存在原因：没有创建同义词【

古城微笑少年丶/ 2023年06月13日 13:26/ 0 赞/ 13 阅读

相关【kafka】kafka record is corrupt（记录损坏）

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

àì夳堔傛蜴生んèń/ 2022年08月30日 11:46/ 0 赞/ 202 阅读

相关 oracle record is locked by another user

先说说问题的由来：下午修改数据库中的表，修改完成后保存但是没有提交，这时突然要去别的地方调试，拔掉网线，然后在插上网线，就出现了这个record is locked by an

Dear 丶/ 2022年08月05日 07:26/ 0 赞/ 168 阅读

相关 c++ delete指针时报错堆损坏 HEAP CORRUPTION DETECTED

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4

我就是我/ 2022年04月24日 09:34/ 0 赞/ 196 阅读

相关 ORACLE数据库删除表中记录报record is locked by another user

在操作ORACLE数据库的时候，由于执行完，没有COMMIT，直接把PL/SQL关闭掉，后来导致那张表被锁住，当编辑时就会出现这个信息，record is locked

古城微笑少年丶/ 2022年03月29日 15:20/ 0 赞/ 209 阅读

相关 “Your python3 install is corrupted”

I just ran into this problem on Pop!\_OS 18.04, trying to upgrade to 18.10, and it turns

骑猪看日落/ 2021年12月11日 07:41/ 0 赞/ 372 阅读