1초에 1000개의 쿠폰 생성 요청이 발생했다고 가정하자.

• 애플리케이션 서버와 DB가 직접 연결된 경우, 1초 동안 DB에 쿠폰 생성 요청이 1000개 발생함 → DB 부하 급증, 타임 아웃, 쿠폰 요청 처리하는 동안 서버에서 다른 서비스 동작 안함
• 애플리케이션 서버와 DB가 카프카 토픽으로 느슨하게 연결된 경우, 쿠폰 처리에 1초가 걸린다고 가정할 때 1초에 1개의 요청 발생함 → 처리량 조절, 서버에서 다른 요청과 병렬 처리 가능
• 동시성을 의도적으로 낮추어서 처리량을 늘리는 방법이다.

작업환경 세팅

도커 컴포즈 : 단일 서버에서 여러개의 컨테이너를 하나의 서비스로 정의해 컨테이너의 묶음으로 관리할 수 있는 작업 환경

# kafka-dir/docker-compose.yaml
version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    container_name: zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka:2.12-2.5.0
    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-compose up -d

카프카 실행종료

docker-compose down