Kafka キューからのメッセージを消費するワーカー サービスを作成し、数秒ごとにメッセージをキューに追加するテスト スクリプトも作成しました。
私が気付いたのは、メッセージがキューに追加されている間、コンシューマーが一度に数分間アイドル状態で座っていることが多いということです。すると突然、消費者は最初のメッセージを受け取り、それを処理し、すぐに残りのメッセージに移ります。最終的には追いつくのですが、そもそもなぜこんなに遅れているのでしょうか。
Kafka キューからのメッセージを消費するワーカー サービスを作成し、数秒ごとにメッセージをキューに追加するテスト スクリプトも作成しました。
私が気付いたのは、メッセージがキューに追加されている間、コンシューマーが一度に数分間アイドル状態で座っていることが多いということです。すると突然、消費者は最初のメッセージを受け取り、それを処理し、すぐに残りのメッセージに移ります。最終的には追いつくのですが、そもそもなぜこんなに遅れているのでしょうか。