当使用者在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.Consumer的配置
{
"bootstrap.servers": "private.kafka.host",
"group.id": "foo.bar",
"auto.offset.reset": "earliest",
"enable.auto.commit": false,
}