Spring Cloud Stream 재시도 구현하기

간단 소개

Spring Cloud Stream을 사용하여 재시도 로직을 구현하고, 관련 개념 및 설정 방법을 소개합니다.

AI Summary

Spring Cloud Stream 재시도 구현 배경
- MySQL Replication Master/Slave DB 간 싱크 문제로 Slave DB 조회 시 간헐적 오류 발생
- Spring Cloud Stream의 재시도 기능으로 DB 싱크 시간 확보
재시도 관련 주요 개념
- 백오프(BackOff): 재시도 간 시간 간격을 점진적으로 늘려 시스템 부하를 줄임
- 예외 처리: 예외 유형에 따라 재시도 여부 결정 (NPE와 같은 예외는 재시도 불필요)
- BackOffExhaust: 최대 재시도 횟수 초과 시 에러 발생 및 로그 기록
Spring Cloud Stream 재시도 구현 방법
- YAML 설정: max-attempts, back-off-initial-interval 등으로 재시도 옵션 설정
- @StreamRetryTemplate: RetryTemplate 빈 등록을 통해 재시도 정책 설정, 함수별 재시도 정책 지정 가능
- 주의: @StreamRetryTemplate 사용 시 YAML 설정은 무시됨, Bean 등록 우선순위 고려 필요