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

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

    评论

报告相同问题?