第 16 章 使用 Cruise Control 修改主题复制因素

流程

1. 启动 Cruise Control 服务器。默认情况下，服务器在端口 9092 上启动；（可选）指定不同的端口。

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

   Copy to Clipboard Toggle word wrap

2. 要验证 Cruise Control 是否正在运行，请将 GET 请求发送到 Cruise Control 服务器的 /state 端点：

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

   Copy to Clipboard Toggle word wrap

3. 使用 --describe 选项运行 bin/kafka-topics.sh 命令，并检查目标主题的当前复制因素：

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

   Copy to Clipboard Toggle word wrap

4. 更新主题的复制因素：

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

   Copy to Clipboard Toggle word wrap

   例如，curl -X POST 'localhost:9090/kafkacruisecontrol/topic_configuration?topic=topic1&replication_factor=3&dryrun=false'。

5. 使用 --describe 选项运行 bin/kafka-topics.sh 命令，以查看对主题的更改结果。