5.5. デュアルロールノードへの移行

手順

1. 各コントローラーノードについて、1 つずつ次の手順を実行します。

   1. コントローラーノードを停止します。

      ./bin/kafka-server-stop.sh

   2. ブローカー固有の設定を追加して、コントローラー専用ノードをデュアルロールノードとして機能するように設定します。

      少なくとも次の操作を実行します。

      • process.roles=controller を process.roles=broker, controller に切り替えます。
      • log.dirs を使用してブローカーのログディレクトリーを追加または更新します。
      • ブローカーがクライアントリクエストを処理するためのリスナーを追加します。この例では、PLAINTEXT://:9092 を追加します。
      • listener.security.protocol.map を使用して、リスナー名とセキュリティープロトコル間のマッピングを更新します。
      • inter.broker.listener.name を使用してブローカー間通信用のリスナーを設定します。

      デュアルロール設定の例

      process.roles=broker, controller
      node.id=1
      
      log.dirs=/var/lib/kafka
      metadata.log.dir=/var/lib/kafka-metadata
      
      listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9090
      controller.listener.names=CONTROLLER
      listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
      controller.quorum.bootstrap.servers=localhost:9090
      inter.broker.listener.name=PLAINTEXT
      
      num.partitions=1
      auto.create.topics.enable=false
      default.replication.factor=3
      min.insync.replicas=2
      # ...

   3. デュアルロールで動作するようになったノードを再起動します。

      ./bin/kafka-server-start.sh -daemon ./config/kraft/dual-role.properties

2. Cruise Control の remove_broker エンドポイントを使用して、現在デュアルロールノードとして機能するようになったノードに、ブローカー専用ノードからパーティションレプリカを再割り当てします。

   クラスター内のトピックとパーティションの数によっては、再割り当てに時間がかかる場合があります。

   詳細は、「最適化プロポーザルの生成」 を参照してください。

3. ブローカーノードを登録解除します。

   ./bin/kafka-cluster.sh unregister \
     --bootstrap-server <broker_host>:<port> \
     --id <node_id_number>

   詳細は、「スケールダウン操作後のノードの登録解除」 を参照してください。

4. ブローカーノードを停止します。

   ./bin/kafka-server-stop.sh