LikeTech Main.

내가 보려고 만든 kafka 명령어 모음

Seokkyu Ryu
Seokkyu Ryu

요새 카프카 관련 토이 프로젝트를 진행하고 있다.
그래서 카프카 명령어를 확인할 일이 있는 데, 내가 자주 쓰는 카프카 명령어를 빠르게 확인하기 위해 적어놓으려고 한다.

Kafka .sh 파일들 확인

cd /opt/kafka // kafka home
cd bin

Kafka 토픽 삭제

kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic { topic name }

아래와 같은 명령어는 최근 카프카 버전에서는 안 먹히는 것 같다. Connection time out 에러가 발생한다.

kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic { topic name }

Kafka 토픽 생성

kafka-topics.sh --bootstrap-server localhost:9092 --create --topic { topic name }

Kafka consumer가 consume하는 메시지 확인

kafka-console-consumer.sh --topic { topic name } --bootstrap-server localhost:9092 --from-beginning

Kafka 토픽 리스트 조회

kafka-topics.sh --list --bootstrap-server localhost:9092

Kafka 특정 그룹 컨슈머들 상태 확인

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group { group id } --describe