[Kafka] 카프카 명령어 정리

카프카 설치 폴더 의 bin 폴더로 이동하면 카프카 상태를 확인할 수 있는 몇가지 쉘 들이 있다. 결국 이를 이용하는 것이 카프카 명령어다.

 

토픽리스트 확인

./kafka-topics.sh --list --bootstrap-server ${broker-host}

 

토픽생성

./kafka-topics.sh --create --topic ${topic-name} --zookeeper ${zookeeper-host} --partitions 1 --replication-factor 1

 

토픽 상세보기

./kafka-topics.sh --describe --bootstrap-server ${broker-host} --topic ${topic-name}

 

토픽에 데이터 넣기

./kafka-console-producer.sh --broker-list localhost:9092 --topic ${topic-name}

 

토픽데이터 확인

 - 이 명령어는 tail 기능이 포함되어 있어 실시간으로 프로듀싱 되는 데이터를 확인할 수 있다.

./kafka-console-consumer.sh --bootstrap-server ${broker-host} --topic ${topic-name} --from-beginning

 

토픽의 현재 offset 확인

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${broker-host} --topic ${topic-name}

 

https://pinggoopark.tistory.com/6
https://mongsil-jeong.tistory.com/42