Cara cepat untuk mencipta topik Kafka

Steps dengan cepat membuat topik kafka

1. import dependencies

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

e

2. create 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();
    }
}

e

3. run code

mvn exec:java

e

4. verify sama ada topik dicipta dengan berjaya
r

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

e

Jika anda melihat topik

, ini bermakna topik itu berjaya dibuat. my-topic

Nota

Apabila mencipta tema, anda perlu menentukan nama tema dan bilangan partition. Bilangan partition menentukan bilangan mesej yang boleh diproses oleh topik secara serentak.
• Apabila mencipta topik, anda juga boleh menentukan parameter lain, seperti bilangan salinan, jenis mampatan, dsb.
• Selepas mencipta topik, anda boleh menghantar mesej kepada topik tersebut.
• Apabila menggunakan mesej, anda boleh menentukan kumpulan pengguna. Kumpulan pengguna menentukan pengguna yang boleh menggunakan mesej dalam topik.

Atas ialah kandungan terperinci Cara cepat untuk mencipta topik Kafka. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!