Kafka 주제를 만드는 빠른 방법

Kafka 주제를 빠르게 생성하는 단계

1. 종속성 가져오기

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

2. Kafka AdminClient 만들기

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

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

public class CreateTopic {

    public static void main(String[] args) {
        // 创建Properties对象，并设置Kafka集群的地址
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "localhost:9092");

        // 创建AdminClient对象
        AdminClient adminClient = AdminClient.create(properties);

        // 创建NewTopic对象，并设置主题名称和分区数
        NewTopic newTopic = new NewTopic("my-topic", 3);

        // 创建主题
        adminClient.createTopics(Collections.singletonList(newTopic));

        // 关闭AdminClient对象
        adminClient.close();
    }
}

3. 코드 실행

mvn exec:java

4. 주제가 성공적으로 생성되었습니다

kafka-topics --list --zookeeper localhost:2181

my-topic 토픽이 보이면 해당 토픽이 성공적으로 생성되었다는 의미입니다.

Notes

• 테마를 생성할 때 테마 이름과 파티션 수를 지정해야 합니다. 파티션 수에 따라 주제가 동시에 처리할 수 있는 메시지 수가 결정됩니다.
• 주제를 생성할 때 복사본 수, 압축 유형 등과 같은 다른 매개변수를 지정할 수도 있습니다.
• 주제를 만든 후 해당 주제에 메시지를 보낼 수 있습니다.
• 메시지를 소비할 때 소비자 그룹을 지정할 수 있습니다. 소비자 그룹은 주제의 메시지를 사용할 수 있는 소비자를 결정합니다.

위 내용은 Kafka 주제를 만드는 빠른 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!