3.5. KRaft モードでの Kafka クラスターの実行

手順

1. kafka-storage ツールを使用して一意の Kafka クラスター ID を生成します。

   ./bin/kafka-storage.sh random-uuid

   この ID はすべてのノードで再利用されるため保存します。

2. 各ノードの設定ファイルを作成します。

   設定ファイルは、Kafka で提供されている例に基づいて作成します。

   • コントローラー専用ノードの controller.properties
   • ブローカー専用ノードの broker.properties
   • 両方のロールを持つノードの server.properties
   注記

   サンプルの server.properties ファイルでは、静的クォーラム設定を目的とした controller.quorum.voters がデフォルトで使用されます。動的クォーラム (推奨) を使用するには、この手順に示すように、これを controller.quorum.bootstrap.servers に置き換えます。controller.properties ファイルは、デフォルトで controller.quorum.bootstrap.servers を使用します。

   ノードごとに、以下のプロパティーを調整します。

   node.id=1
   process.roles=broker,controller
   controller.quorum.bootstrap.servers=node1:9093,node2:9093,node3:9093
   listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093
   advertised.listeners=PLAINTEXT://node1:9092
   inter.broker.listener.name=PLAINTEXT
   controller.listener.names=CONTROLLER
   log.dirs=/var/lib/kafka/data

   重要な考慮事項:

   • 各ノードには一意の node.id が必要です。
   • listeners のホスト名 (0.0.0.0) はすべてのインターフェイスにバインドされますが、必要に応じて各ノードごとに特定のホスト名または IP アドレスに変更できます。
   • advertised.listeners は、クライアントが Kafka ノードに接続するために使用する実際のアドレスを反映する必要があります。
   • 設定ファイル内の log.dirs パスは、メタデータが保存される場所を定義します。設定されていない場合は、デフォルトで一時的な場所に設定され、再起動時に消去されるため、開発にのみ適しています。

3. コントローラークォーラムをブートストラップします (コントローラーは 1 つのみ)。

   ./bin/kafka-storage.sh format --cluster-id <uuid> --standalone --config ./config/controller.properties

   これにより、メタデータログが初期化され、クォーラムがブートストラップされます。1 つのノードでのみ使用してください。<uuid> は、生成されたクラスター ID に置き換えます。

   注記

   複数のコントローラーでブートストラップするには、代わりに --initial-controllers を使用します。

4. コントローラーを起動します。

   ./bin/kafka-server-start.sh ./config/controller.properties

5. クォーラムにコントローラーを追加します。

   すべてのノードで controller.quorum.bootstrap.servers が正しく設定され、コントローラーが起動されていることを確認します。

6. 残りのノード (ブローカー) をフォーマットします。

   ./bin/kafka-storage.sh format --cluster-id <uuid> --config ./config/server.properties --no-initial-controllers

   各ノードのロールに基づいて適切な設定ファイルを使用します。すべてのノードに同じクラスター ID を使用します。この手順では、コントローラークォーラムを変更せずに各ノードのストレージを準備します。

7. 各ブローカーノードを起動します。

   ./bin/kafka-server-start.sh ./config/server.properties

8. Kafka が稼働していることを確認します。

   jcmd | grep kafka

   戻り値:

   process ID kafka.Kafka ./config/server.properties

   各ノードのログをチェックして、KRaft クラスターに正常に参加していることを確認します。

   tail -f ./logs/server.log