Kafka 입문·실전 - 2.5. [실습] Spring Boot에 Kakfa 연결을 위한 코드 추가하기
- 스프링 부트 프로젝트 설정을 위해 start.spring.io에서 Gradle, Java, 3.x 버전, Email-Send-Producer 아티팩트, emailsendproducer 패키지, Jar 패키징, Java 21 버전을 선택 🛠️
- 의존성으로 Spring Boot DevTools, Spring Web, Kafka 추가 ➕
- 프로젝트 생성 후 압축을 풀고 IntelliJ에서 프로젝트를 열어 빌드 📂
- application.properties 파일을 application.yml로 변경 후 설정 초기화 🔄
- application.yml 파일에 Kafka 서버 연결을 위한 설정 추가 (bootstrap-servers, key-serializer, value-serializer) ⚙️
- bootstrap-servers에는 AWS EC2 인스턴스의 퍼블릭 IP 주소와 포트 9092를 입력 🌐
- key-serializer와 value-serializer는 메시지의 키와 값을 직렬화하는 방식을 설정 (여기서는 StringSerializer 사용) 🔑
- StringSerializer는 자바 객체를 문자열 형태로 변환하여 Kafka에 메시지를 전송하는 데 사용 💬
- 카프카 설정을 완료하고, 다음 강의에서 스프링 부트를 이용해 카프카에 메시지를 넣는 프로듀서 관련 코드 작성 예정 🚀