핵심 요약
리디(RIDI)가 Kafka를 이벤트 버스로 활용해 감상 데이터 게시-구독으로 실시간 랭킹을 구현하고, 서비스 간 데이터 흐름의 확장성을 확보했습니다.
구현 방법
- 감상 데이터가 'reading-books' 토픽에 게시되고 랭킹 서비스가 구독
- CloudEvents 포맷과 KafkaJS 기반의 Node.js 생산/소비
- R-Bus 팀이 다양한 이벤트를 처리하고 InfluxDB로 KPI를 시계열 저장, 대시보드 운영
주요 결과
- 최대 초당 수만 개의 메시지 처리 가능
- 응답 속도 및 안정성 향상, 의존성 감소
- 데이터 흐름의 확장성 확보
