AI 요약관련 정보

• 스프링 부트로 Kafka 컨슈머를 구현하여 메시지를 조회하고 처리하는 방법을 설명합니다. 📧
• start.spring.io에서 필요한 의존성(DevTools, Spring Web, Kafka)을 추가하여 프로젝트를 생성합니다. 🛠️
• application.yml 파일에서 서버 포트 설정 및 Kafka 연결 정보를 설정합니다. ⚙️
• key.deserializer와 value.deserializer를 설정하여 메시지 키와 값을 역직렬화하는 방법을 정의합니다. 🔑
• auto.offset.reset을 earliest로 설정하여 컨슈머 그룹이 없을 경우 처음부터 메시지를 읽도록 설정합니다. ⏪
• Kafka에서 가져온 메시지를 담을 EmailSend 메시지 객체를 생성하고, JSON 형태의 메시지를 객체로 변환하는 메서드를 추가합니다. ✉️
• @KafkaListener 어노테이션을 사용하여 특정 토픽의 메시지를 컨슈머 그룹으로 읽어들이는 로직을 구현합니다. 👂
• 컨슈머 그룹을 통해 메시지를 읽으면 오프셋 정보가 Kafka에 저장되어 중복 처리 없이 메시지를 순차적으로 처리할 수 있습니다. 💾