卡夫卡消费者在超过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 在这里被定义为confluen -kafka-go,但无法找到它的出处。 如果出现任何此类错误,为什么程序不退出?

  • Kafka v1.1.0
  • librdkafka v1.0.0
  • confluent-kafka-go (master)

用于kafka.Consumer的配置

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