go - 超过 max.poll.interval.ms 后，Kafka 消费者卡住了

Question

当消费者在 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已定义 here在 confluent-kafka-go 中，但无法找到它在哪里被提出。

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

卡夫卡 v1.1.0

librdkafka v1.0.0

confluent-kafka-go(大师)

用于 kafka.Consumer 的配置

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

Answer 1

看起来这是向 confluent-kafka-go 客户端报告的问题:https://github.com/confluentinc/confluent-kafka-go/issues/344
它被标记为已解决，该更改本应在 librdkafka 1.1.0 版中发布:https://github.com/edenhill/librdkafka/commit/80e9b1ee0c0e477c02f18b130c4302240711a88d
看起来这个变化也应该在 confluent-kafka-go 1.1.0 版中发布:https://github.com/confluentinc/confluent-kafka-go/tree/v1.1.0
问题中的一些评论仍然报告说这是版本 > 1.1.0 上的问题体验。
一位评论者建议解决以下问题:

Using v1.5.2. Also calling ReadMessage(-1) in an infinite loop, and not seeing rejoining after consumer leaving group, worked around it by setting timeout to be less than max.poll.interval.ms instead of -1, but wondering why it's not rejoining as expected.

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