P82282866/kt-event-marketing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
kt-event-marketing/develop/mq/mq-exec-dev.md
wonho 781c3944ed MQ 설치 결과서 작성 (개발 환경) 
- Kafka 브로커 정보 추가 (4.230.50.63:9092)
- Consumer Group ID 설정 (ai, analytic)
- Spring Boot 연결 설정 예시 포함
- 토픽 설정 및 연결 테스트 방법 추가

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>
2025-10-23 16:50:09 +09:00

1.9 KiB
Raw Blame History

MQ 설치 결과서 (개발 환경)

설치 정보

Kafka 브로커 정보

  • Host: 4.230.50.63
  • Port: 9092
  • Broker 주소: 4.230.50.63:9092

Consumer Group ID 설정

서비스 Consumer Group ID 설명
ai ai AI 서비스용 Consumer Group
analytic analytic 분석 서비스용 Consumer Group

연결 설정 예시

Spring Boot 설정 (application.yml)

spring:
  kafka:
    bootstrap-servers: 4.230.50.63:9092
    consumer:
      group-id: ai  # 또는 analytic
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

환경 변수 설정

export KAFKA_BOOTSTRAP_SERVERS=4.230.50.63:9092
export KAFKA_CONSUMER_GROUP_ID=ai  # 또는 analytic

설치 확인

연결 테스트

# Kafka 브로커 연결 확인
kafka-broker-api-versions --bootstrap-server 4.230.50.63:9092

# 토픽 목록 확인
kafka-topics --bootstrap-server 4.230.50.63:9092 --list

# Consumer Group 목록 확인
kafka-consumer-groups --bootstrap-server 4.230.50.63:9092 --list

토픽 설정

AI 서비스 관련 토픽

  • ai-request: AI 요청 메시지 토픽
  • ai-response: AI 응답 메시지 토픽
  • ai-schedule: AI 일정 생성 메시지 토픽

Analytic 서비스 관련 토픽

  • analytic-event: 분석 이벤트 메시지 토픽
  • analytic-result: 분석 결과 메시지 토픽

설치 날짜

  • 작성일: 2025-10-23

비고

  • 개발 환경(dev)용 Kafka 설정
  • 각 서비스별 Consumer Group ID가 분리되어 독립적인 메시지 소비 가능
  • 필요시 추가 토픽 생성 및 Consumer Group 추가 가능