[java] 자바로 카프카 토픽 생성하기

16 Nov 2023

java

이번에는 자바를 사용하여 카프카 토픽을 생성하는 방법에 대해 알아보겠습니다.

카프카 토픽 생성하기

카프카에서 토픽을 생성하기 위해서는 AdminClient를 사용해야 합니다. 다음은 자바 코드를 사용하여 카프카 토픽을 생성하는 예제입니다.

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.NewTopic;

import java.util.Properties;
import java.util.Collections;

public class KafkaTopicCreator {

    public static void main(String[] args) {
        // Kafka 관리용 AdminClient 설정
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        // AdminClient 생성
        AdminClient adminClient = AdminClient.create(props);

        // 토픽 생성
        String topicName = "my-topic";
        int numPartitions = 1;
        int replicationFactor = 1;
        NewTopic newTopic = new NewTopic(topicName, numPartitions, replicationFactor);
        adminClient.createTopics(Collections.singleton(newTopic));

        // AdminClient 종료
        adminClient.close();
    }
}

위의 예제 코드에서는 AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG 속성을 이용하여 카프카 브로커의 주소를 설정하고, NewTopic 객체를 생성하여 토픽을 정의합니다. 그리고 AdminClient를 통해 createTopics 메서드를 호출하여 토픽을 생성합니다. 마지막으로 adminClient.close()를 호출하여 AdminClient를 종료합니다.

위의 예제 코드를 실행하면 my-topic이라는 이름의 토픽이 생성됩니다.

참고 자료

이제 자바를 사용하여 카프카 토픽을 생성하는 방법에 대해 알아보았습니다. 자세한 내용은 위의 참고 자료를 참고하시기 바랍니다.