BE[feat]_AI_서버_Kafka Consumer

[dyk000825]

[AI 서버용 Kafka Consumer 개발]

간단 설명

AI 서버에서 Kafka chat.to-ai 토픽을 구독하여 사용자 원본 메시지를 수신할 수 있도록 Kafka Consumer를 구현합니다.

• Kafka Consumer 설정
• 원본 메시지 역직렬화 및 파싱
• 변환 처리용 서비스로 메시지 전달

상세 설명

AI 서버는 Kafka에서 사용자 입력 메시지를 수신하여 말투 변환 작업을 수행해야 합니다.
이를 위해 chat.to-ai 토픽을 구독하는 Consumer를 생성하고, JSON 형식의 메시지를 DTO로 역직렬화하여 처리 서비스에 전달합니다.

Spring Kafka 또는 Python 기반 Kafka Client(like kafka-python) 중 선택하여 구현할 수 있으며, Consumer Group을 통해 병렬 처리도 가능하게 구성합니다.