Chapter 16. Using Cruise Control to modify topic replication factor

Procedure

1. Start the Cruise Control server. The server starts on port 9092 by default; optionally, specify a different port.

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

   Copy to Clipboard Toggle word wrap

2. To verify that Cruise Control is running, send a GET request to the /state endpoint of the Cruise Control server:

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

   Copy to Clipboard Toggle word wrap

3. Run the bin/kafka-topics.sh command with the --describe option and to check the current replication factor of the target topic:

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

   Copy to Clipboard Toggle word wrap

4. Update the replication factor for the topic:

   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

   For example, curl -X POST 'localhost:9090/kafkacruisecontrol/topic_configuration?topic=topic1&replication_factor=3&dryrun=false'.

5. Run the bin/kafka-topics.sh command with the --describe option, as before, to see the results of the change to the topic.