
1. Kafka: 오픈 소스 분산 이벤트 스트리밍 플랫폼으로, 대량의 데이터 스트리밍을 실시간으로 처리할 수 있도록 설계된 메시지 브로커(Message Broker)입니다. source application(클릭로그/결제로그)과 target appplication(로그적재/로그처리)의 결합도를 줄이기 위해서 나왔다. 각종 데이터를 담는 topic, queue의 역할을 하는 것이 있다. 데이터를 넣는 역할은 Producer, 데이터를 가져가는 Consumer는 라이브러리로 되어있어 어플리케이션에서 쉽게 쓸 수 있음.📌 Kafka의 주요 개념1. Producer (생산자)Kafka에 데이터를 발행(전송)하는 클라이언트데이터를 특정 토픽(Topic)에 보냄데이터를 파티션(Partition) 단위로 나눠 저장..

* 목표: 최근 본 상품을 기반으로 생성된 메시지를 카카오 알림톡으로 자동 전송해보자.* 방법: 카카오 알림톡은 사업자 등록증이 필요한 비즈니스 인증만을 허용하므로 카카오 메시지 API로 대체해서 구현해보자. 1. 카카오 개발자 센터에서 https://developers.kakao.com/ Kakao Developers카카오 API를 활용하여 다양한 어플리케이션을 개발해보세요. 카카오 로그인, 메시지 보내기, 친구 API, 인공지능 API 등을 제공합니다.developers.kakao.com새로운 애플리케이션 생성하고 로그인 ON으로 변경. 2. 카카오 로그인 (OAuth 연동)redirect URI 설정: http://localhost:8080/login/oauth2/code/kakao- 카카오 인증이..
✅ 1️⃣ AI 기반 추천 시스템의 동작 방식💡 목표:사용자가 특정 상품을 조회하면, AI가 해당 사용자의 이전 행동 데이터를 분석하여 최적의 상품을 추천한다. [사용자 이벤트 발생 (상품 조회)] ↓ [Kafka] → [Redis (이전 본 상품 저장)] ↓ [AI 추천 시스템 (추천 상품 생성)] ↓ [추천 메시지 생성 및 전송 (SMS, 이메일, 푸시)] ✅ 2️⃣ 1단계: 사용자 행동 데이터 저장 (상품 조회 이벤트 저장)👉 사용자가 상품을 조회하면, 해당 이벤트를 Kafka에 저장하고, Redis에서 조회 이력을 관리한다.public class UserEvent { private String userId; private St..