1. 카프카 설치 경로로 이동
cd /opt/kafka
2. 주키퍼 실행 상태 확인
service zookeeper status
3. 카프카 실행 상태 확인
service kafka status
4. 카프카 토픽 전체 확인
./bin/kafka-topics.sh --list --zookeeper localhost:2181
5. test 라는 이름을 가진 토픽 만들기
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test
6. 전체 토픽 조회하기
./bin/kafka-topics.sh --list --zookeeper localhost:2181
7. 토픽 상세보기
./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
8. test2 이름을 가진 토픽을 만들고, 레플리카는 1개 파티션은 3개로 설정해보기
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test2
9. 전체 토픽 조회하기
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
10. test 토픽 상세조회해보기
./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
11. test2 토픽 상세조회해보기
./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test2
12. test 토픽 삭제해보기
./bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test
13. 전체 토픽 조회하기
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
14. test2 토픽 제거하기
./bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test2
15. 전체 토픽 조회해보기
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
'Data Engineering > Kafka' 카테고리의 다른 글
[kafka] 도커컴포즈로 싱글노드 카프카 만드는 방법 (docker compose, single, kafka, zookeeper) (0) | 2021.12.23 |
---|---|
[kafka] 카프카의 구성요소 (0) | 2021.12.19 |
[kafka] 카프카 예제 및 명령어 공부 3 (0) | 2021.06.14 |
[kafka] 카프카 예제 및 명령어 공부 1 (0) | 2021.06.13 |
[kafka] 카프카 명령어 모음 Kafka Command Collection (2) | 2021.05.21 |