🔙뒤로가기

Kafka 설치 및 구성이 완료되었다면 Spring Boot 애플리케이션에서 Spring Kafka 라이브러리를 프로젝트에 추가해야 한다.

1. Gradle 빌드 파일 수정

Spring Boot 프로젝트에서 Kafka를 사용하려면, 프로젝트의 build.gradle 파일에 Spring Kafka 의존성을 추가해야 한다.

build.gradle

implementation 'org.springframework.kafka:spring-kafka'

2. Spring Boot Kafka 구성

application.properties 또는 application.yml 파일에 Kakfa 서버의 주소를 지정해야 한다. 만약 로컬에서 실행하는 경우 다음과 같다.

spring:
  kafka:
    bootstrap-servers: localhost:9092
# 실제 프로덕션 환경에서는 여러 Kafka 브로커를 ','로 구분하여 나열할 수 있다.
#		**bootstrap-servers: kafka1:9092,kafka2:9092,kafka3:9092**

이 설정은 Spring Boot 애플리케이션에게 Kafka 브로커가 **localhost**의 9092 포트에서 실행되고 있다는 것을 알려준다. 참고로, **localhost:9092**는 Kafka의 기본 설정이며, 실제 Kafka 서버의 설정에 따라 달라질 수 있다.

3. 이벤트 생성 및 전송

사용자 활동에 따른 이벤트를 생성하고 이를 Kafka로 전송하는 Java 로직을 구현해야 한다. 이를 위해 KafkaTemplate를 사용하여 메시지를 Kafka 토픽에 전송할 수 있다. 예를 들어, 다음과 같이 사용자 활동 이벤트를 생성하고 전송하는 서비스를 만들 수 있다.

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class UserActivityService {

    private final KafkaTemplate<String, UserActivity> kafkaTemplate;

    public UserActivityService(KafkaTemplate<String, UserActivity> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    public void sendActivity(UserActivity activity) {
        kafkaTemplate.send("user-activities", activity);
    }
}

여기서 **UserActivity**는 사용자 활동을 나타내는 예시 클래스이다. 이 클래스는 사용자 ID, 활동 유형, 시간, 답변 내용 등의 필드를 포함해야 할 것이다. 또한, **user-activities**는 이벤트를 전송할 Kafka 토픽의 이름이다. Kafka 토픽은 메시지를 카테고리별로 구분하는 데 사용되며, 각 토픽에는 관련된 메시지들이 저장된다. 따라서 토픽의 이름은 저장되는 메시지의 내용을 잘 나타낼 수 있도록 정의해야 한다.

테스트

이제 프로젝트를 실행하고 사용자 활동을 Kafka로 전송하는 기능을 테스트해볼 수 있다.

단위 테스트

애플리케이션의 코드 내에서 직접 테스트를 수행할 수도 있다. 이를 위해서는 Spring Kafka에서 제공하는 **KafkaTestUtils**와 같은 도구를 사용하거나, Mock 객체를 사용해 Kafka 연결을 모방하는 방법이 있다.

통합 테스트

애플리케이션과 Kafka 사이의 실제 통신을 테스트한다. 로컬에 설치된 Kafka를 사용하거나, Docker를 사용하여 Kafka 컨테이너를 실행하여 테스트를 수행할 수 있다. 통합 테스트를 사용하면 애플리케이션과 Kafka 간의 실제 통신이 잘 이루어지는지 확인할 수 있다.