Un moyen rapide de créer un sujet Kafka

Étapes pour créer rapidement un sujet Kafka

1. Importer des dépendances

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

2. Créer un client administrateur Kafka

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. Exécuter le code

mvn exec:java

4. Vérifiez si le sujet est créé avec succès

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

Si vous voyezmy-topic sujet, cela signifie que le sujet a été créé avec succès.

Notes

• Lors de la création d'un thème, vous devez spécifier le nom du thème et le nombre de partitions. Le nombre de partitions détermine le nombre de messages qu'une rubrique peut traiter simultanément.
• Lors de la création d'un sujet, vous pouvez également spécifier d'autres paramètres, tels que le nombre de copies, le type de compression, etc.
• Après avoir créé un sujet, vous pouvez envoyer des messages vers ce sujet.
• Lors de la consommation de messages, vous pouvez spécifier un groupe de consommateurs. Le groupe de consommateurs détermine quels consommateurs peuvent consommer les messages du sujet.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!