카프카 명령어 정리

Docker에서 실행법

docker-compose -f docker-compose.yml up -d

 

카프카 쉘 진입법(kafka는 docker에 올라간 컨테이너 이름)

docker exec -it kafka /bin/sh

cd /opt/kafka_2.13-2.8.1/bin 으로 진입 ls로 확인하면 여러 파일이 있어 여기서 토픽 관련 명령어 수행 가능합니다.

 

카프카 토픽 생성

kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic {topic_name}

repication-factor는 브로커 1개이며 partition 1개로 생성하는 명령어입니다. 권장 브로커는 3개입니다.

 

카프카 토픽 리스트 출력

kafka-topics.sh --list --zookeeper zookeeper:2181

 

카프카 토픽 삭제

kafka-topics.sh --delete --zookeeper zookeeper:2181 --topic (topic_name)

 

카프카 토픽 정보 조회

kafka-topics.sh --describe --zookeeper zookeeper:2181 --topic (topic_name)

 

Producer 데이터 조회

kafka-console-producer.sh --broker-list zookeeper:2181 --topic (topic_name)

 

Consumer 데이터 조회(실제 데이터 조회)

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic (topic_name) --from-beginning