[kafka] 카프카 명령어 모음 Kafka Command Collection

주키퍼 실행

./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

카프카 실행

./bin/kafka-server-start.sh -daemon config/server.properties

토픽 생성

./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

토픽 리스트 확인

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

토픽 상세보기

./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test

토픽에 데이터 넣기 (프로듀서)

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

토픽의 데이터 확인 (컨슈머)

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

토픽 삭제하기

config 폴더 안에있는 server.properties 파일을 vi 편집기로 열어서 아래 내용 추가

delete.topic.enable=true

그리고 다시 상위폴더로 이동해서

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

컨슈머 그룹 리스트 확인

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

컨슈머 그룹 상태 확인

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