[Kafka] topic 관련 명령어/ topic CLI

아파치카프카 로고

1️⃣ #토픽 만들기

- first_topic 이라는 이름을 가진 토픽 만들기

kafka-topics.sh --bootstrap-server localhost:9092 --topic first_topic --create

create topics

2️⃣ topic 리스트 확인하기

kafka-topics.sh --bootstrap-server localhost:9092 --list

topics list

3️⃣ #partition 을 가진 토픽 만들기

- 3개의 파티션을 가진 second_topic 이라는 이름을 가진 토픽 만들기

kafka-topics.sh --bootstrap-server localhost:9092 --topic second_topic --create --partitions 3

 

4️⃣ #복제계수

- 복제계수 :  재해 복구의 목적과 고가용성을 위해서 여러 서버에 토픽을 복사하는 방법. 복제계수는 브로커의 개수보다 크면 안된다.

kafka-topics.sh --bootstrap-server localhost:9092 --topic third_topic --create --partitions 3 --replication-factor 1

5️⃣ topics 상세 내용 확인하기

 

6️⃣ topic 지우기

kafka-topics.sh --bootstrap-server localhost:9092 --topic second_topic --delete
# (only works if delete.topic.enable=true)