[kafka] 카프카 토픽(Topic) 명령어 및 실행 예시

# Topic 생성 하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

2. boker-ip : 172.0.0.001:9092,172.0.0.02:9092,172.0.0.03:9092

# --replication-factor 3
# 토픽의 각 파티션을 복제할 복제본의 수를 설정
# 브로커 중 하나가 다운되더라도 다른 복제본이 데이터를 유지

# --partitions 3
# 생성할 파티션의 수를 설정합니다. 여기서는 3개의 파티션이 생성

# --bootstrap-server <broker-ip>
# Kafka 클러스터의 브로커 주소를 설정
#
./kafka-topics.sh --create --replication-factor 3 --partitions 3 --topic test --bootstrap-server <broker-ip>

 

---

# Topic list 확인하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

./kafka-topics.sh --list --bootstrap-server <broker-ip>

 

---

# Topic 상세 정보 확인하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

./kafka-topics.sh --describe --topic test --bootstrap-server <broker-ip>

 

---

# Topic partition 개수 수정하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

2. 주의! 파티션은 한 번 늘리면 다시 줄일 수 없다.

./kafka-topics.sh --alter --topic test --partitions 5 --bootstrap-server <broker-ip>

 

---

# Topic Replica 개수 수정하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

 

• rf.json 파일 생성

{
   "version": 1,
   "partitions": [
           {"topic":"test2", "partition": 0, "replicas":[1,2,3]}
    ]
}

./kafka-reassign-partitions.sh --reassignment-json-file rf.json --execute --bootstrap-server <broker-ip>

 

---

# Topic 삭제하기

1. 경로 /opt/kafka_2.13-3.7.1/bin

./kafka-topics.sh --delete --topic test --bootstrap-server <broker-ip>

 

---

# Producer 테스트 해보기

1. 경로 /opt/kafka_2.13-3.7.1/bin

./kafka-console-producer.sh --topic test --bootstrap-server <broker-ip>

 

---

# Consumer 테스트 해보기

1. 경로 /opt/kafka_2.13-3.7.1/bin

./kafka-console-consumer.sh --topic test --from-beginning  --bootstrap-server <broker-ip>

 

---

참고자료

Topic 관련 명령어

[Kafka] 구축 해보기[2] - topic 관련 명령어