次のセットアップのapache-kafka 0.8クラスターがあります-
1) 3 つのブローカーがすべて同じマシンで実行されている
2) 10 個のパーティションと 3 つのレプリカを持つ 1 つのトピック。
1 つのトピックに対して 20 人のプロデューサーがいます。
各パーティションから 10 人の消費者が消費しています。ブローカーのフェールセーフをテストしています。
すべてのブローカーが稼働している場合、消費されるメッセージの数は、生成されるメッセージの数と同じです。
しかし、ブローカーを 1 つずつダウンさせてセットアップをテストすると、生成されるよりも多くのメッセージが消費されることがわかりました。
同じ理由として何が考えられますか?