kafka & zookeeper cli
— Kafka, Command, DevOps — 1 min read
토픽 생성
kafka-topics.sh --create --topic {topic name} --bootstrap-server {kafka host:port} --replication-factor 1 --partitions 1토픽 목록 조회
kafka-topics.sh --list --bootstrap-server {kafka host:port}토픽 정보 조회
kafka-topics.sh --bootstrap-server {kafka host:port} --topic {topic name} --describe특정 토픽으로 메시지 발행
kafka-console-producer.sh --broker-list {kafka host:port} --topic {topic name}특정 토픽으로 발행된 메시지 pulling
--from-beginning: 해당 토픽의 맨 처음 메시지부터 확인 가능
kafka-console-consumer.sh --bootstrap-server {kafka host:port} --topic {topic name}zookeeper CLI 접속
- 주키퍼 설치 디렉토리 내부
/bin폴더로 이동하여 다음 커맨드 입력
zkCli.sh startznode 생성하기
create {생성할 znode 경로}create /kafka_local