Spring Cloud Stream 재시도 구현하기

이 글은 사람인 기술 블로그에서 DB Trigger를 비동기 분산 처리로 변환하는 과정에서 발생한 Kafka 메시지 처리 문제를 Spring Cloud Stream과 Spring Retry를 활용하여 재시도 로직으로 해결한 경험을 공유합니다. 기존 시스템에서 MySQL Replication Master와 Slave DB 간의 싱크 지연으로 인해 Slave DB 조회 시 간헐적으로 데이터 불일치 문제가 발생했습니다.

이 문제를 해결하기 위해 Spring Cloud Stream의 재시도 기능을 활용했으며, 특히 Spring Retry 라이브러리를 사용하여 특정 함수에 대한 재시도 횟수 및 세부 설정을 효율적으로 구현하는 방법을 설명합니다. 이를 통해 메시지 처리 과정의 안정성을 높이고 간헐적인 오류를 효과적으로 관리할 수 있었습니다.