kafka를 활용한 STOMP 채팅 서비스 구축 (2)

카프카 설치 및 구동

docker-compose.yml 구성

zookeeper:
        image: wurstmeister/zookeeper
        container_name: zookeeper
        ports:
          - '2181:2181'
    kafka:
        image: wurstmeister/kafka
        container_name: kafka
        ports:
          - '9092:9092'
        environment:
          KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
          KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
        volumes:
          - /var/run/docker.sock:/var/run/docker.sock

간단하게 동작 확인을 위해서 싱글 브로커로 구성하였다.

카프카 접속

docker exec -it kafka /bin/bash

토픽 생성

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

토픽 리스트 확인

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

프로듀서 실행

kafka-console-producer.sh --topic chatting --broker-list kafka:9092

컨슈머 실행

kafka-console-consumer.sh --topic chatting --bootstrap-server kafka:9092

실행 확인

잘 구동되는 것을 확인할 수 있다.

---

Reference

https://9hyuk9.tistory.com/92