java maven프로젝트에서 kafka를 사용할수 있도록 설명하는 내용을 정리

Java Maven 프로젝트에서 Kafka를 사용할 수 있도록 하는 방법과 Kafka에 메시지를 쓰고 구독하는 샘플 코드를 아래와 같이 정리했습니다.

Kafka 사용 환경 설정 (Maven)

1. Maven 의존성 추가 (pom.xml)

Kafka 클라이언트 라이브러리 kafka-clients를 프로젝트 의존성에 추가합니다.

xml

<dependency>

<groupId>org.apache.kafka</groupId>

<artifactId>kafka-clients</artifactId>

<version>3.9.0</version>

</dependency>

위 버전은 2025년 최신 기준 예시이며, 필요에 따라 조정 가능합니다.

메시지 쓰기 (Producer) 및 구독 (Consumer) 샘플 코드

Producer (메시지 전송)

java

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

import org.apache.kafka.clients.producer.ProducerConfig;

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

import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class SimpleProducer {
public static void main(String[] args) {
String bootstrapServers = “localhost:9092”;
String topic = “my-topic”;

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

KafkaProducer<String, String> producer = new KafkaProducer<>(props);

ProducerRecord<String, String> record = new ProducerRecord<>(topic, “Hello from Java Maven Kafka!”);

producer.send(record, (metadata, exception) -> {
if(exception == null) {
System.out.printf(“Sent message to topic=%s partition=%d offset=%d%n”,
metadata.topic(), metadata.partition(), metadata.offset());
} else {
exception.printStackTrace();
}
});

producer.flush();
producer.close();
}
}

Consumer (메시지 구독)

java

import org.apache.kafka.clients.consumer.ConsumerConfig;

import org.apache.kafka.clients.consumer.ConsumerRecord;

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

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

import org.apache.kafka.common.serialization.StringDeserializer;

import java.time.Duration;
import java.util.Collections;
import java.util.Properties;

public class SimpleConsumer {
public static void main(String[] args) {
String bootstrapServers = “localhost:9092”;
String topic = “my-topic”;
String groupId = “my-group”;

Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, “earliest”);

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList(topic));

System.out.println(“Listening to topic: “ + topic);
while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
System.out.printf(“Received message: key=%s value=%s partition=%d offset=%d%n”,
record.key(), record.value(), record.partition(), record.offset());
}
}
}
}

요약

kafka-clients 라이브러리를 Maven pom.xml에 추가하여 Kafka API를 사용 가능하게 합니다.
간단한 Producer, Consumer 클래스를 작성하여 Kafka 브로커(localhost:9092)에 메시지를 쓰고 읽을 수 있습니다.
메시지 보내기(producer.send)는 비동기로 처리하며, 콜백에서 성공/실패 결과를 처리합니다.
메시지 구독 시 poll 메서드를 통해 주기적으로 메시지를 받아 처리합니다.

이 코드들을 Java Maven 프로젝트에 추가하면 Kafka와 기본적인 메시징 통신이 가능합니다.