Kafka 기본 명령어

Kafka 로그 확인

cat /kafka(설치된 카프카 디렉토리)/logs/server.log

 

Zookeeper 실행

/zookeeper(설치된 주키퍼 디렉토리)/bin/zkServer.sh start

 

Kafka topic 생성

./kafka-topics.sh --zookeeper [주키퍼1 ip]:2181,[주키퍼2 ip]:2181,[주키퍼3 ip]:2181/localhost.localdomain_znode --replication-factor 1 --partitions 1 --topic [토픽명] --create

 

카프카 메세지 전송

실행 위치 (/kafka(설치된 카프카 디렉토리)/bin)
./kafka-console-producer.sh --topic [토픽명] --broker-list [카프카 ip]:9092

 

카프카 메세지 전송(키값 줘서)

./kafka-console-producer.sh --topic topic19 --broker-list 172.30.1.22:9092,172.30.1.66:9092,172.30.1.91:9092 --property "parse.key=true" --property "key.separator=:"

 

토픽리스트 조회

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

 

컨슈머 상태와 오프셋 확인

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test-consumer --describe

 

컨슈머 그룹 리스트 확인

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

 

 

카프카 메세지 수신

./kafka-console-consumer.sh --topic [토픽명] --bootstrap-server [카프카 ip]:9092 --from-beginning

 

카프카 토픽 삭제

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic MyTopic