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

手順

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

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

   Copy to Clipboard Toggle word wrap

   このコマンドは ID を返します。KRaft モードでクラスター ID が必要です。

2. クラスターの各ブローカーに設定プロパティーファイルを作成します。

   ファイルは、Kafka で提供される例に基づくことができます。

   1. デュアルロールを broker, `controller または broker, controller として指定します。

      たとえば、デュアルロールに、process.roles=broker, controller を指定します。

   2. クラスター内の各ノードに 0 から始まる一意の node.id を指定します。

      たとえば、node.id=1 です。

   3. <node_id>@<hostname:port> の形式で controller.quorum.voters のリストを指定します。

      たとえば、controller.quorum.voters=1@localhost:9093 です。

3. Kafka クラスターの各ノードにログディレクトリーを設定します。

   /opt/kafka/bin/kafka-storage.sh format -t <uuid> -c /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap

   戻り値:

   Formatting /tmp/kraft-combined-logs

   Copy to Clipboard Toggle word wrap

   <uuid> を生成したクラスター ID に置き換えます。クラスター内の各ノードで、同じ ID を使用します。

   ブローカー用に作成したプロパティーファイルを使用してブローカー設定を適用します。

   server.properties 設定ファイルに指定されたデフォルトのログディレクトリーの場所は /tmp/kraft-combined-logs です。複数のログディレクトリーを設定するには、コンマ区切りリストを追加できます。

4. 各 Kafka ブローカーを起動します。

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

   Copy to Clipboard Toggle word wrap

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

   jcmd | grep kafka

   Copy to Clipboard Toggle word wrap

   戻り値:

   number kafka.Kafka /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap