[실습] Spring Boot에 Kafka 연결을 위한 코드 추가하기

← 블로그 목록으로 돌아가기

author

JSCODE 박재성

✅ Spring Boot에 Kafka 연결하기

동일한 환경에서 실습을 진행하기 위해 아래 버전을 사용할 것을 권장한다. - Spring Boot는 3.x.x 버전 - JDK 21

Spring Boot 프로젝트 셋팅

start.spring.io

https://start.spring.io/

Artifact와 Name을 email-send-producer라고 지어주자.

Package name을 Java 컨벤션에 맞게 emailsendproducer라고 지어주자.

Java 21 버전을 선택하자. 아래 과정을 Java 21 버전을 기준으로 진행할 예정이다.

Dependencies는 Spring Boot DevTools, Spring Web, Spring for Apache Kafka를 선택해라.

application.yml에 Kafka 연결을 위한 정보 작성하기

이 프로젝트에서는 application.properties를 지우고 application.yml을 생성했다.

application.yml


spring:
  kafka:
    # Kafka 서버 주소 (EC2에 카프카를 설치했기 때문에 EC2 주소를 입력해야 한다.)
    bootstrap-servers: 15.164.96.71:9092
    producer:
      # 메시지의 key 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      # 메시지의 value 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

👨🏻‍🏫

기본적으로 Spring Boot에 설정해야 하는 Kafka 설정을 해봤다. 다음 강의에서는 Spring Boot로 kafka에 메시지를 넣는 Producer에 관련된 코드를 작성해보자.

author

JSCODE 박재성

category

Kafka

createdAt

Dec 6, 2025 05:14 AM

isPublic

series

실전에서 바로 써먹는 Kafka 입문

slug

type

series-footer

updatedAt

📎

이 글은 실전에서 바로 써먹는 Elasticsearch 입문 (검색 최적화편) 강의의 수업 자료 중 일부입니다.

spring: kafka: # Kafka 서버 주소 (EC2에 카프카를 설치했기 때문에 EC2 주소를 입력해야 한다.) bootstrap-servers: 15.164.96.71:9092 producer: # 메시지의 key 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송 key-serializer: org.apache.kafka.common.serialization.StringSerializer # 메시지의 value 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송 value-serializer: org.apache.kafka.common.serialization.StringSerializer