[아파치 카프카 어플리케이션 프로그래밍] 2. 카프카 프로듀서, 컨슈머 실행해보기 (with Docker)

"책으로 공부하는 Apache Kafka"

 

카프카 설치

교재에서는 AWS EC2를 사용하여 설치하고 있지만, Docker를 사용하여 실습해보자.

https://devfunny.tistory.com/429

docker로 Kafka, Zookeeper 설치 (with docker-compose)

 

Mac Docker 설치

https://docs.docker.com/desktop/mac/install/

 

 

• Kafka가 실행중인 docker conatiners

 

 

토픽 생성 및 조회

• 1) docker kafka 컨테이너 접속

docker container exec -it kafka bash

 

• 2) 토픽 생성
  • 토픽명 : test_topic

kafka-topics.sh --create --topic test_topic --bootstrap-server localhost:9092 --partitions 1

 

• 3) 토픽 리스트 조회

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

 

• 4) 토픽 상세 조회
  • 토픽명 : test_topic

kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test_topic

 

 

프로듀서/컨슈머 수행

• 1) 프로듀서 수행

kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic

 

• 2) 컨슈머 수행
  • 이때 프로듀서를 수행하는 터미널 외의 1개의 새로운 터미널 창을 열고 실행하자.

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning

 

 

 

메시지 전달과정

1) 프로듀서에서 "hello" 라는 메시지를 보낸다.

 

2) 컨슈머에서 hello 가 출력된다.