BE[feat]-채팅기능_AI 연동

[dyk000825]

[AI 연동]

간단 설명

AI 서버가 Kafka로부터 원본 메시지를 수신하고, 변환된 메시지를 다시 Kafka로 발행하는 구조를 구현

• Kafka Consumer로 사용자 메시지 수신
• 말투 변환 처리 후 Kafka Producer로 메시지 재전송

상세 설명

Kafka 토픽 chat.to-ai에서 사용자 메시지를 수신하여, AI 서버가 문체/말투 변환 처리를 수행
변환이 완료된 메시지는 다시 Kafka chat.from-ai 토픽으로 발행되어 백엔드 서버가 이를 수신하고 사용자에게 WebSocket으로 전달

AI 서버는 Kafka 전용 컨슈머 및 프로듀서를 별도로 구현해야 하며, JSON 메시지 포맷 및 메시지 ID, 타임스탬프 등 공통 DTO 설계에 따라 메시지를 직렬화/역직렬화 필수.