[java] 카프카와 자바를 이용한 이벤트 기반 웹 애플리케이션 개발하기

16 Nov 2023

java

이벤트 기반 웹 애플리케이션은 비동기적으로 동작하며, 느슨하게 결합된 컴포넌트들 간에 이벤트를 주고받으면서 동작하는 시스템을 의미합니다. 이러한 시스템은 확장성과 유연성을 제공하면서 이벤트의 처리를 통해 비즈니스 로직을 구현할 수 있습니다.

이번 블로그 포스트에서는 카프카와 자바를 이용하여 이벤트 기반 웹 애플리케이션을 개발하는 방법을 알아보겠습니다.

1. 카프카 소개

카프카는 분산 스트리밍 플랫폼으로, 대용량의 실시간 데이터 피드를 가공하고 저장할 수 있습니다. 이벤트 기반 웹 애플리케이션에서는 카프카를 통해 이벤트를 발행하고 구독하는 역할을 수행합니다. 이를 통해 애플리케이션 간 데이터 흐름을 관리하고, 데이터의 신뢰성과 확장성을 보장할 수 있습니다.

2. 카프카와 자바 연동하기

카프카를 자바로 연동하기 위해서는 먼저 카프카 클라이언트 라이브러리를 프로젝트에 추가해야 합니다. 다음은 Maven을 사용하는 경우의 의존성 설정 예시입니다.

<dependencies>
  <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.0</version>
  </dependency>
</dependencies>

연동을 위한 주요 클래스는 Producer와 Consumer입니다. Producer는 이벤트를 발행하는 역할을 하고, Consumer는 이벤트를 구독해서 처리하는 역할을 합니다. 아래는 간단한 예제 코드입니다.

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import java.util.Properties;

public class EventBasedApplication {
    private static final String TOPIC = "my-topic";
    private static final String BOOTSTRAP_SERVERS = "localhost:9092";

    public static void main(String[] args) {
        // Producer 예제
        Properties producerProps = new Properties();
        producerProps.put("bootstrap.servers", BOOTSTRAP_SERVERS);
        producerProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        producerProps.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<String, String> producer = new KafkaProducer<>(producerProps);
        producer.send(new ProducerRecord<>(TOPIC, "key", "value"));
        producer.close();

        // Consumer 예제
        Properties consumerProps = new Properties();
        consumerProps.put("bootstrap.servers", BOOTSTRAP_SERVERS);
        consumerProps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        consumerProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        consumerProps.put("group.id", "my-group");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(consumerProps);
        consumer.subscribe(Collections.singletonList(TOPIC));

        while (true) {
            ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
            for (ConsumerRecord<String, String> record : records) {
                System.out.println("Received event: " + record.value());
            }
        }
    }
}

3. 이벤트 기반 웹 애플리케이션 개발하기

이벤트 기반 웹 애플리케이션을 개발하기 위해서는 먼저 이벤트의 발행자(Publisher)와 수신자(Subscriber)를 구현해야 합니다. 예를 들어, 사용자의 등록 이벤트를 발행하고, 이를 처리하는 사용자 서비스를 구현하고자 한다면 다음과 같은 스텝을 따를 수 있습니다.

카프카 프로듀서를 사용하여 사용자 등록 이벤트를 발행합니다.
카프카 컨슈머를 사용하여 등록된 사용자 이벤트를 수신합니다.
수신된 이벤트를 처리하는 사용자 서비스를 구현합니다.

위에서 소개한 예제 코드와 카프카의 이벤트 처리 기능을 활용하여 웹 애플리케이션에서 이벤트 기반 아키텍처를 구현할 수 있습니다.

4. 결론

카프카와 자바를 이용하여 이벤트 기반 웹 애플리케이션을 개발하는 방법을 알아보았습니다. 카프카를 통해 이벤트를 발행하고 구독하는 기능을 사용해 비동기적이고 유연한 애플리케이션을 구현할 수 있습니다. 이를 통해 애플리케이션의 확장성과 신뢰성을 향상시킬 수 있습니다.