<aside> 💡

요약

Paragon kafka 구성 흐름 ( producer and consumer errorHandler … )

</aside>

• 목차

Paragon Spring Kafka 구조 정리

Producer

• 역할:
  • 데이터를 생성하여 특정 Kafka Topic으로 전송.
• 동작 방식:
  • Spring KafkaTemplate을 사용하여 메시지를 전송.
• 연결된 Topic:
  • 운영/개발 환경을 포함하여 대략 6개의 Topic으로 메시지 전송.

Consumer

• 역할:
  • 지정된 Kafka Topic에서 메시지를 읽어와 처리.
• 동작 방식:
  • @KafkaListener를 사용하여 Topic을 구독하고, 메시지를 받아 처리.
• MDC 설정:
  • Listener 인터셉터를 통해 MDC에 정보를 담고, Sentry로 예외 정보를 전송.
• 에러 핸들링:
  • 기본 DefaultErrorHandler를 사용하고, 10번 재시도 후 커밋을 하고 다음 메시지로 넘김.
• DLT 사용: X

Sentry 및 MDC 연동

• MDC 설정:
  • Listener 마다 인터셉터가 반영하여 Kafka 메시지의 Offset, Partition, Topic 정보를 MDC에 저장
• Sentry 전송:
  • 예외 발생 시 MDC 정보를 Sentry에 전송하여 추적이 가능.

개선 사항 및 고려 사항