第7章 Node ページ
Node ページには、ブローカー、コントローラー、またはデュアルロールを実行するノードを含む、Kafka クラスター用に作成されたすべてのノードがリスト表示されます。リストは、ノードプール、ロール (ブローカーまたはコントローラー)、またはステータスでフィルターできます。
各ノードのステータスを表示できます。ブローカーノードの場合、このページには、パーティションリーダーとフォロワーの数を含む、クラスター全体のパーティション分散が表示されます。
ブローカーのステータスは次のいずれかとして表示されます。
- Not Running
- ブローカーは、まだ起動されていないか、明示的に停止されています。
- Starting
- ブローカーはクラスターを初期化して接続しています。メタデータクォーラムを検出して参加しています。
- Recovery
- ブローカーはクラスターに参加しましたが、回復モードです。必要なデータとメタデータを複製してから、完全に動作可能な状態になります。まだクライアントのリクエストに応答していません。
- Running
- ブローカーは完全に稼働しています。コントローラーに登録され、クライアントの要求に対応します。
- Pending Controlled Shutdown
- ブローカーが正常なシャットダウンを開始しました。実行中の操作が完了すると、正常にシャットダウンします。
- Shutting Down
- ブローカーはシャットダウンしています。クライアント接続が切断され、内部リソースが解放されています。
- Unknown
- ブローカーの状態は不明です。予期しないエラーまたは障害が原因である可能性があります。
ブローカーにラック ID がある場合は、ブローカーが存在するラックまたはデータセンターを識別します。
コントローラーのステータスは次のいずれかとして表示され、メタデータクォーラム内でのコントローラーのロールを示します。
- Quorum leader
- コントローラーはアクティブなリーダーであり、クラスターのメタデータの更新を調整し、パーティションの再割り当てやブローカーの登録などの操作を管理します。
- Quorum follower
- コントローラーはメタデータクォーラムのフォロワーであり、同期状態を維持しながらリーダーからの更新を受動的に複製します。必要に応じてリーダーとしてのロールを引き継ぐ準備ができています。
- Quorum follower lagged
- コントローラーはフォロワーですが、リーダーに情報が追いついていません。最新のメタデータと完全に同期できていないため、追いつくまでリーダー選出の対象とならない可能性があります。
- Unknown
- 予期しないエラーまたは障害が原因で、コントローラーの状態が不明です。
ノード名の横にある右矢印 (>) をクリックすると、ホスト名やディスク使用量など、ノードの詳細情報が表示されます。
クラスターで実行されている再バランスを表示するには、Rebalance タブをクリックします。
パーティションが均一的に分散されていない場合は、リソースを効率的に使用できるようにリバランスを検討してください。
7.1. リバランスの管理 リンクのコピーリンクがクリップボードにコピーされました!
クラスター上で最適化提案を生成するように KafkaRebalance リソースを設定すると、Rebalance タブからそのステータスを確認できます。Rebalance タブには、最適化提案を管理できる KafkaRebalance リソースの時系列リストが表示されます。名前、ステータス、またはリバランスモードでリストをフィルターできます。
Rebalance タブを使用するには、Kafka クラスターと並行して Cruise Control を実行できるようにする必要があります。Cruise Control を設定して使用し、提案を生成する方法は、Streams for Apache Kafka のドキュメント を参照してください。
手順
- Streams for Apache Kafka Console で Kafka クラスターにログインし、Kafka nodes をクリックします。
Rebalance タブの情報を確認します。
各リバランスのステータスと最終更新時刻を表示できます。
Expand 表7.1 リバランスステータスの説明 ステータス 説明 NewOperator によってリソースがまだ認識されていない
PendingProposal最適化提案は生成されない
ProposalReady最適化提案は承認待ちである
Rebalancingリバランスが進行中
Stoppedリバランス停止した
NotReadyリバランス中にエラーが発生した
Readyリバランスが完了した
ReconciliationPausedリバランスは一時停止されている
注記strimzi.io/pause-reconciliationアノテーションが設定でtrueに設定されている場合、KafkaRebalanceリソースのステータスはReconciliationPausedに変わります。- リバランス名の横にある右矢印 (>) をクリックすると、リバランスモードや自動承認が有効かどうかなど、リバランスに関する詳細情報が表示されます。リバランスによりブローカーが削除または追加された場合は、それらもリストされます。
最適化提案は、次の 3 つのモードのいずれかで生成できます。
-
fullはデフォルトのモードで、完全なリバランスを実行します。 -
add-brokersは、Kafka クラスターをスケールアップするときにブローカーを追加した後に使用されるモードです。 -
remove-brokersは、Kafka クラスターをスケールダウンするときにブローカーを削除する前に使用されるモードです。
提案の自動承認が有効になっていると、正常に生成された提案はクラスターの再バランスに直接送られます。
最適化提案の表示
生成された最適化提案を表示するには、KafkaRebalance リソースの名前をクリックします。最適化プロポーザルは、パーティションのワークロードをブローカー間でより均等に分散することで、Kafka クラスターの負荷をより均等にするために提案された変更の概要です
提案に表示されるプロパティーとその意味の詳細は、Streams for Apache Kafka のドキュメント を参照してください。
リバランスの管理
オプションアイコン (縦に並んだ 3 つのドット) を選択し、オプションをクリックしてリバランスを管理します。
-
提案を承認するには、Approve をクリックします。
提案で概説されているリバランス調整は、Kafka クラスターで実行されます。 -
新しい最適化提案を生成するには、Refresh をクリックします。
提案の生成と承認の間にギャップがあった場合は、クラスターの現在の状態がリバランスで考慮されるように提案を更新します。 -
リバランスを停止するには、Stop をクリックします。
リバランスには長い時間がかかり、クラスターのパフォーマンスに影響を与える可能性があります。リバランスを停止すると、パフォーマンスの問題を回避し、必要に応じて変更を元に戻すことができます。
利用可能なオプションは、KafkaBalance リソースのステータスによって異なります。たとえば、最適化提案の準備ができていない場合は承認できません。