Kafkaキューへの書き込みと読み取りの間に遅延があるのはなぜですか？

Question

私はKafkaキューからメッセージを消費するワーカーサービスを作成しました。また、数秒ごとにキューにメッセージを追加するためのテストスクリプトも作成しました。

私が気づいたことは、メッセージがキューに追加されている間に、コンシューマが一度に数分間アイドル状態になることが多いことです。そして、突然、消費者は最初のメッセージを受け取って処理し、その後すぐに残りのメッセージに移動します。だからそれは最終的にキャッチアップするが、私は最初にそのような遅延がなぜあるのだろうかと思っている？

Answer 1

コンシューマグループは連絡先コーディネータに連絡し、遅延中に自動的に割り当て済みのパーティションを取得するまでに数回かかります。

手動割り当てを使用すると、遅延が少なくなります。