[java] 카프카와 자바를 이용한 이벤트 소싱 및 이벤트 적재 구현하기

16 Nov 2023

java

이벤트 소싱(event sourcing)은 마이크로서비스 아키텍처에서 많이 사용되는 패턴 중 하나입니다. 이 패턴을 사용하면 시스템의 상태를 변경하는 모든 이벤트를 기록하고 저장할 수 있습니다. 이벤트 소싱은 시스템의 상태를 일관성 있게 관리하고, 시간에 따른 변경 사항을 추적할 수 있게 해줍니다.

이번 글에서는 카프카와 자바를 이용하여 이벤트 소싱과 이벤트 적재를 구현하는 방법에 대해 알아보겠습니다.

카프카와 이벤트 소싱의 개요

카프카는 분산 스트리밍 플랫폼으로, 높은 처리량과 확장성을 제공합니다. 이벤트 소싱을 구현하기 위해서는 카프카를 사용하여 이벤트 스트림을 만들고, 이벤트를 소비하는 컨슈머를 구현해야 합니다.

이벤트 소싱의 핵심 아이디어는 시스템의 상태를 변경하는 모든 동작을 이벤트로 표현하고, 이벤트를 저장하는 것입니다. 이벤트에는 변경이 일어난 데이터의 상태 변경 정보가 포함되어 있습니다. 시스템의 상태를 조회할 때는 이벤트 스트림을 순차적으로 읽어서 이벤트를 처리하여 최신 상태를 만듭니다. 이렇게 하면 모든 변경 사항이 저장되므로, 데이터의 상태를 어떤 시점으로 되돌릴 수도 있습니다.

이벤트 소싱과 이벤트 적재를 위한 자바 코드

이제 이벤트 소싱과 이벤트 적재를 위한 자바 코드를 살펴보겠습니다. 아래는 이벤트를 나타내는 자바 클래스입니다.

public class Event {
    private String eventType;
    private String data;
    // 생성자, getter, setter 메소드 생략
}

다음으로 이벤트를 생산(produce)하는 프로듀서 코드입니다.

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

public class EventProducer {
    private final KafkaProducer<String, Event> producer;
    private final String topic;

    public EventProducer(String topic) {
        this.topic = topic;
        // KafkaProducer 초기화 코드
        // producer = new KafkaProducer<>(properties);
    }

    public void produce(Event event) {
        ProducerRecord<String, Event> record = new ProducerRecord<>(topic, event);
        producer.send(record);
    }
}

위의 코드에서 EventProducer는 카프카 프로듀서를 생성하고, produce 메소드를 통해 이벤트를 전송합니다.

이벤트를 처리(consume)하는 컨슈머 코드는 다음과 같습니다.

import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;

public class EventConsumer {
    private final KafkaConsumer<String, Event> consumer;
    private final String topic;

    public EventConsumer(String topic) {
        this.topic = topic;
        // KafkaConsumer 초기화 코드
        // consumer = new KafkaConsumer<>(properties);
        consumer.subscribe(Collections.singletonList(topic));
    }

    public void consume() {
        while (true) {
            ConsumerRecords<String, Event> records = consumer.poll(Duration.ofMillis(100));
            // 이벤트 처리 코드
            for (ConsumerRecord<String, Event> record : records) {
                Event event = record.value();
                // 이벤트 처리 로직 작성
            }
        }
    }
}

위의 코드에서 EventConsumer는 카프카 컨슈머를 생성하고, consume 메소드를 통해 이벤트를 처리합니다.

결론

이벤트 소싱 패턴은 시스템의 상태 변경을 이벤트로 기록하여 데이터의 일관성을 유지하고, 상태 변화를 추적하는 데 유용한 방법입니다. 카프카를 사용하여 이벤트 스트림을 만들고, 자바를 사용하여 이벤트를 소비하고 처리할 수 있습니다. 위의 코드를 참고하여 이벤트 소싱 및 이벤트 적재를 구현해보세요.

참고 자료

카프카 공식 문서