1. 주키퍼 실행 확인
service zookeeper status
2. 카프카 실행 상태 확인
service kafka status
3. 카프카 설치된 곳으로 이동하기
cd /opt
cd kafka
4. 전체 토픽 확인하기
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
5. test 이름을 가진 토픽 만들기
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
6. 토픽 전체 조회하기
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
7. 토픽에 메세지를 프로듀서로 넣어보기
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
a
b
c
ctrl+c
8. test 토픽을 컨슈머로 조회해보기
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
ctrl+c
메세지를 확인했으면 ctrl+c로 빠져나오기
9. 토픽 상세 보기
./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
10. 토픽 삭제해보기
./bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test
11. 전체 토픽 조회하기
./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] 카프카 예제 및 명령어 공부 2 (0) | 2021.06.14 |
[kafka] 카프카 명령어 모음 Kafka Command Collection (2) | 2021.05.21 |