# 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>
참고자료
[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 |