コンシューマーが 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
ここで confluent-kafka-go でErrMaxPollExceeded定義されていることがわかりますが、それが発生している場所を見つけることができません。
このようなエラーが発生した場合、プログラムが終了しないのはなぜですか?
- カフカ 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,
}