第14章 Cruise Control を使用したトピックレプリケーション係数の変更

手順

1. Cruise Control サーバーを起動します。デフォルトでは、サーバーはポート 9092 で起動します。オプションで別のポートを指定します。

   cd /opt/cruise-control/
   ./kafka-cruise-control-start.sh config/cruisecontrol.properties <port_number>

2. Cruise Control が実行していることを確認するには、Cruise Control サーバーの /state エンドポイントに GET リクエストを送信します。

   curl -X GET 'http://<cc_host>:<cc_port>/kafkacruisecontrol/state'

3. --describe オプションを指定して bin/kafka-topics.sh コマンドを実行し、ターゲットトピックの現在のレプリケーション係数を確認します。

   /opt/kafka/bin/kafka-topics.sh \
     --bootstrap-server localhost:9092 \
     --topic <topic_name> \
     --describe

4. トピックのレプリケーション係数を更新します。

   curl -X POST 'http://<cc_host>:<cc_port>/kafkacruisecontrol/topic_configuration?topic=<topic_name>&replication_factor=<new_replication_factor>&dryrun=false'

   たとえば、curl -X POST 'localhost:9090/kafkacruisecontrol/topic_configuration?topic=topic1&replication_factor=3&dryrun=false' とします。

5. 前述の手順と同様に、--describe オプションを指定して bin/kafka-topics.sh コマンドを実行し、トピックへの変更の結果を確認します。