Kafkaのブローカー上のパーティション再バランス0.8

Question

Kafka 0.8に関する比較的稀な文書には、既存のトピック、パーティション、およびブローカー上のレプリカのバランスを取るために期待される動作については言及されていません。

具体的には、ブローカーの到着時やブローカー（リーダーまたはそれ以外）のクラッシュ時に予想される動作は何ですか？

ありがとうございました。

Answer 1

私はそれらの2つのケースを以前のうちにテストしましたが、重い負荷ではありません。私は1人のプロデューサに2つのブローカのクラスタに2つのパーティションを持つ2の複製係数でトピックに同期して10kメッセージ（ちょっとした文字列）を送信させます。 2人の消費者がいます。各コンポーネントは別のマシンにデプロイされます。私が観察したことは次のとおりです。通常の動作で

• ：ブローカー1は、パーティション2ブローカー2のパーティション1とレプリカでリーダーであるにブローカー3を持参パーティション1パーティション2とレプリカ上のリーダーですクラスタは自動的にパーティションの再調整をトリガーしません。

• ：再調整は、プロデューサとコンシューマに対してトランスペアレントです。再起動ブローカーはログを最初に複製してから、それ自体を使用可能にします。いずれかのブローカーに殺すことによってシミュレート-9：ブローカーで

• は（リーダーまたはしない）墜落しました。殺されたブローカーのZKの一時的なノードが期限切れになるまで、プロデューサーとコンシューマーはフリーズします。その後、正常に動作を再開します。