본문 바로가기
시리즈/카프카

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

by 되고싶은노력가 2024. 7. 19.

# 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 관련 명령어

공통경로 : /usr/local/kafka/bin : 172.16.10.151:9092,172.16.10.152:9092,172.16.10.153:9092   Topic 생성 하기 ./kafka-topics.sh --create --replication-factor 1 --partitions 3 --topic test2 --bootstrap-server     Topic list 확인하기./ka

ploz.tistory.com

 

'시리즈 > 카프카' 카테고리의 다른 글

[kafka] 카프카 클러스터(Cluster) 구축  (0) 2024.07.18
[kafka] 카프카의 개념  (0) 2024.07.18