7.7. 주제 생성

주제 생성

1. kafka-topics.sh 유틸리티를 사용하여 주제를 생성하고 다음을 지정합니다.

   • --bootstrap-server 옵션에 있는 Kafka 브로커의 호스트 및 포트입니다.
   • --create 옵션에 생성할 새 주제입니다.
   • --topic 옵션의 주제 이름입니다.
   • --partitions 옵션의 파티션 수입니다.

   • --replication-factor 옵션의 복제 요인입니다.

     --config 옵션을 사용하여 일부 기본 주제 구성 옵션을 덮어쓸 수도 있습니다. 이 옵션을 여러 번 사용하여 다른 옵션을 덮어쓸 수 있습니다.

     /opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_address> --create --topic <TopicName> --partitions <NumberOfPartitions> --replication-factor <ReplicationFactor> --config <Option1>=<Value1> --config <Option2>=<Value2>

     mytopic이라는 주제를 생성하는 명령의 예

     /opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic mytopic --partitions 50 --replication-factor 3 --config cleanup.policy=compact --config min.insync.replicas=2

2. kafka-topics.sh 를 사용하여 주제가 존재하는지 확인합니다.

   /opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_address> --describe --topic <TopicName>

   mytopic이라는 주제를 설명하는 명령의 예

   /opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic mytopic