7.9. 주제 구성 수정

주제 구성 수정

1. kafka-configs.sh 툴을 사용하여 현재 구성을 가져옵니다.

   • --bootstrap-server 옵션에 Kafka 브로커의 호스트 및 포트를 지정합니다.
   • --entity-type 을 topic 및 --entity-name 을 주제 이름으로 설정합니다.

   • 현재 구성을 가져오려면 --describe 옵션을 사용합니다.

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --describe

     mytopic이라는 주제의 구성을 가져오는 명령의 예

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --describe

2. kafka-configs.sh 툴을 사용하여 구성을 변경합니다.

   • --bootstrap-server 옵션에 Kafka 브로커의 호스트 및 포트를 지정합니다.
   • --entity-type 을 topic 및 --entity-name 을 주제 이름으로 설정합니다.
   • 현재 구성을 수정하려면 --alter 옵션을 사용합니다.

   • --add-config 옵션을 추가하거나 변경할 옵션을 지정합니다.

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --alter --add-config <option>=<value>

     mytopic이라는 주제의 구성을 변경하는 명령의 예

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --alter --add-config min.insync.replicas=1

3. kafka-configs.sh 도구를 사용하여 기존 구성 옵션을 삭제합니다.

   • --bootstrap-server 옵션에 Kafka 브로커의 호스트 및 포트를 지정합니다.
   • --entity-type 을 topic 및 --entity-name 을 주제 이름으로 설정합니다.
   • 기존 구성 옵션을 제거하려면 --delete-config 옵션을 사용합니다.

   • --remove-config 명령에서 제거할 옵션을 지정합니다.

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --alter --delete-config <option>

     mytopic이라는 주제의 구성을 변경하는 명령의 예

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --alter --delete-config min.insync.replicas