菜小鸡腿儿 2021-01-05 18:35 采纳率: 0%
浏览 108
已结题

springboot kafka消费者消费多个分区,某一个分区偏移量突然重置,如何解决?

如下截图,报错Fetch offset 1384269296 is out of range for partition GGSN-GPRS-JS-18-01-9, resetting offset,详细如下:

2021-01-05 10:04:45.311  INFO 28439 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=GGSN-GPRS-JS-18-01_ggsn_group_js] Fetch offset 1384269296 is out of range for partition GGSN-GPRS-JS-18-01-9, resetting offset
2021-01-05 10:04:45.315  INFO 28439 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=GGSN-GPRS-JS-18-01_ggsn_group_js] Resetting offset for partition GGSN-GPRS-JS-18-01-9 to offset 1316492213.

 kafka有十个分区,重置的分区为第九分区,该消费者同时消费第八第九两个分区。

请问为啥报错,如何解决呢?

  • 写回答

4条回答 默认 最新

  • weixin_43466240 2021-01-06 11:04
    关注

    kafka中,consumer启动的时候,它不知道从哪个offset开始读取数据,于是它使用一个最大的长整数,这样会引发OffsetOutOfRangeException,当接收到这个错误后,consumer会根据配置中“autooffset.reset”的值来重置offset的值。解决办法就是把offset设置为0

    评论

报告相同问题?

悬赏问题

  • ¥15 素材场景中光线烘焙后灯光失效
  • ¥15 请教一下各位,为什么我这个没有实现模拟点击
  • ¥15 执行 virtuoso 命令后,界面没有,cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 ubuntu子系统密码忘记
  • ¥15 保护模式-系统加载-段寄存器