Kafka消费者在超过max.poll.interval.ms后卡住

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《Kafka消费者在超过max.poll.interval.ms后卡住》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

当消费者在 5 分钟内没有收到消息（max.poll.interval.ms 默认值为 300000ms）时，消费者将停止而不退出程序。消费者进程挂起并且不再消费任何消息。

记录以下错误消息

maxpoll|rdkafka#consumer-1| [thrd:main]: application maximum poll interval (300000ms) exceeded by 255ms (adjust max.poll.interval.ms for long-running message processing): leaving group

我看到 errmaxpollexceeded 是在 confluence-kafka-go 中定义的，但无法找到它的引发位置。

如果出现任何此类错误，为什么程序不退出？

• 卡夫卡 v1.1.0
• librdkafka v1.0.0
• confluence-kafka-go（主）

用于 kafka.consumer 的配置

{
    "bootstrap.servers":    "private.kafka.host",
    "group.id":             "foo.bar",
    "auto.offset.reset":    "earliest",
    "enable.auto.commit":   false,
}

解决方案

看起来这是向 confluence-kafka-go 客户端报告的问题：https://github.com/confluentinc/confluent-kafka-go/issues/344

它被标记为已通过此更改解决，该更改应在 librdkafka 版本 1.1.0 中发布：https://github.com/edenhill/librdkafka/commit/80e9b1ee0c0e477c02f18b130c4302240711a88d

看起来这个更改也应该在 confluence-kafka-go 版本 1.1.0 中发布：https://github.com/confluentinc/confluent-kafka-go/tree/v1.1.0

该问题中的一些评论仍然报告说这是版本 >1.1.0 上遇到的问题。

评论者提出了一种解决方法：

https://github.com/confluentinc/confluent-kafka-go/issues/344#issuecomment-745014864

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。