栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

kafka消费报错 StackTrace: org.apache.kafka.g7.clients.consumer.CommitFailedException

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

kafka消费报错 StackTrace: org.apache.kafka.g7.clients.consumer.CommitFailedException

报错内容如下:

出现上诉问题的原因是在kafka consumer会话超时的时候,没有能把offset提交到broker,所以要么超时时间session.timeout.ms设置的太短了,要么消息的处理太慢了影响了ACK的执行,要么虽然是采用了线程池的方式,但是consumer在把消息入队的时候阻塞了,从而影响ACK。

所以总结下来解决的思路是:

  • 调参 session.timeout.ms
  • 加快消息的消费速度,我推荐的方式是单Consumer拿到消息后放到一个队列中,多线程的方式进行消费处理,设置ShutdownHook保证关闭的时候队列中的消息不丢失
  • 3.采用自动commit的方式,但是有数据丢失的风险

session.timeout.ms参数说明:

用于发现消费者故障的超时时间。消费者周期性的发送心跳到broker,表示其还活着。如果会话超时期满之前没有收到心跳,那么broker将从分组中移除消费者,并启动重新平衡。请注意,该值必须在broker配置的group.min.session.timeout.ms和group.max.session.timeout.ms允许的范围内。

本人解决这个问题的方法是把session.timeout.ms的值调大

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/914143.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号