5대 금융사를 품은 버즈베네핏의 백엔드 팀은 무슨 일을 할까요?
두줄요약
게이미피케이션 확장에 맞춰 Kafka CDC와 Argo Workflow 기반의 데이터·랭킹 파이프라인을 구축했습니다. 모니터링과 Feature Flag로 대규모 트래픽 운영 및 제한적 기능 실험을 지원합니다.
문제 상황
- 광고 송출 중심 시스템에서 게이미피케이션 기능 확장에 따른 데이터 흐름 파편화와 실험 데이터 수집 한계
- 대규모 참여 트래픽 처리, 서비스 간 데이터 일관성, 안정적 랭킹 집계 요구
구조와 흐름
- MySQL 변경 사항을 Kafka와 Confluent JDBC Source·Sink Connector로 전파하는 CDC 기반 DB 동기화
- 참여 이벤트의 S3 적재 후 Argo Workflow 기반 주기적 쿼리·랭킹 집계·DB 적재 자동화
- Datadog APM 및 대시보드, Loki·Grafana 로그 알림, Prometheus 메트릭 기반 컴포넌트·인프라 관측
선택 이유
- 파일럿 특성과 Kafka Consumer 유지보수 비용을 고려한 실시간 대신 주기적 랭킹 집계
- Client와 Manager 인터페이스 분리를 통한 Feature Flag 구현체 교체 용이성
- 제한된 사용자·고객사 대상 기능 노출과 장애 시 즉시 비활성화를 위한 Feature Flag 도입
성능/운영 포인트
- Kafka 기반 이벤트 처리로 참여 증가에 따른 수평 확장과 트래픽 급증 상황의 무중단 운영
- API, Workflow, Kafka, MySQL, Redis, DynamoDB 대상 실시간 알림과 SLO 수준 운영
- Test in Production 및 향후 A/B 테스트 지원 기반


