14장. Cruise Control을 사용하여 주제 복제 요소 수정
복제 요소를 포함하여 주제 구성을 수정하기 위해 Cruise Control REST API의 /topic_configuration 엔드포인트에 요청합니다.
사전 요구 사항
-
kafka사용자로 Red Hat Enterprise Linux에 로그인되어 있습니다. - Cruise Control을 구성했습니다.
- Cruise Control Metrics Reporter를 배포 했습니다.
프로세스
Cruise Control Server를 시작합니다. 서버는 기본적으로 포트 9092에서 시작합니다. 선택적으로 다른 포트를 지정합니다.
cd /opt/cruise-control/ ./kafka-cruise-control-start.sh config/cruisecontrol.properties <port_number>Cruise Control이 실행 중인지 확인하려면 Cruise Control 서버의
/state엔드포인트에 GET 요청을 보냅니다.curl -X GET 'http://<cc_host>:<cc_port>/kafkacruisecontrol/state'bin/kafka-topics.sh명령을--describe옵션으로 실행하고 대상 항목의 현재 복제 요소를 확인합니다./opt/kafka/bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --topic <topic_name> \ --describe항목의 복제 요소를 업데이트합니다.
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:90/kafkacruisecontrol/topic_configuration?topic=topic1&replication_factor=3&dryrun=false'.-
이전과 같이
--describe옵션을 사용하여bin/kafka-topics.sh명령을 실행하여 주제 변경 결과를 확인합니다.