지연이체 서비스 개발기: 은행 점검 시간 끝나면 송금해 드릴게요! (feat. 발표 후기)

간단 소개

카카오페이 지연이체 서비스를 Kafka 기반으로 재설계하고 성능을 8배 향상시킨 개발 경험 공유.

AI Summary

지연이체 서비스 재설계 배경 및 목표
- 기존 RabbitMQ 기반 시스템에서 Kafka 기반으로 전환 필요성 발생
- 은행 점검 시간 이후 자동 송금 기능 유지를 목표
- Kafka 도입을 통해 메시지 큐 시스템 변경 및 서비스 지속성 확보
Kafka 기반 아키텍처 설계 및 구현
- 스케줄러를 통해 송금 건을 읽어 Kafka에 Produce하고, Consumer가 Consume하여 송금 실행
- 중복 송금 방지를 위해 상태 체킹 로직, 유저락 적용, Record Key에 userId를 사용하여 동일 사용자 송금은 동일 Consumer에서 처리되도록 구현
성능 개선 및 결과
- Consumer 수 증가, Batch Read 설정, Multi Thread 적용을 통해 송금 실행 속도 향상
- 1분당 처리 건수가 8배 이상 증가하는 성능 개선 효과 달성
- 아키텍처 설계 시 중복 발생 위험, 동시성 문제, 락 사용, 타 서버 영향 등을 고려해야 함을 강조