第14章 ブローカーの追加または削除によるクラスターのスケーリング

動的コントローラークォーラムは、システムのダウンタイムを必要とせずにスケーリングをサポートします。動的スケーリングは、コントローラーの追加や削除に役立つだけでなく、次の機能もサポートします。

動的クォーラムは、各コントローラーの host:port エンドポイントをリストする controller.quorum.bootstrap.servers プロパティーを使用してコントローラー設定で指定されます。コントローラーのクラスターへの追加またはクラスターからの削除は、一度に 1 つだけ可能です。したがって、複雑なクォーラムの変更は、一連の単一の変更として実装されます。新しいコントローラーは オブザーバー として参加し、メタデータログをレプリケートしますが、クォーラムにはカウントされません。アクティブコントローラーに追いつくと、新しいコントローラーはクォーラムに参加できるようになります。

コントローラーを削除するときは、不要なリーダー選出を避けるために、最初にコントローラーをシャットダウンすることを推奨します。削除されたコントローラーがアクティブなコントローラーである場合、新しいクォーラムの確認後にのみクォーラムから離脱します。ただし、__cluster_metadata ログ内の最後のコミット位置を計算するときには、それ自体は含まれません。

動的クォーラムでは、すべてのクラスターノードのアクティブな Kraft バージョンは 1 以上になります。kafka-features.sh ツールを使用して、アクティブな KRaft バージョンを見つけます。

./bin/kafka-features.sh --bootstrap-controller localhost:9093 describe | grep kraft.version

この出力例では、Kafka クラスター内のアクティブなバージョン (FinalizedVersionLevel) は 1 です。

Feature: kraft.version  SupportedMinVersion: 0  SupportedMaxVersion: 1  FinalizedVersionLevel: 1 Epoch: 5

kraft.version プロパティーにアクティブバージョンレベル 0 が表示されるか存在しない場合は、静的クォーラムを使用しています。1 以上の場合は、動的クォーラムを使用しています。