Schnelle Möglichkeit, ein Kafka-Thema zu erstellen

Schritte zum schnellen Erstellen eines Kafka-Themas

1. Abhängigkeiten importieren

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

2. Kafka AdminClient erstellen

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. Führen Sie den Code aus

mvn exec:java

4. Überprüfen Sie, ob das Thema erfolgreich erstellt wurde

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

Wenn Sie my-topic Thema sehen, bedeutet dies, dass das Thema erfolgreich erstellt wurde.

Hinweise

• Beim Erstellen eines Themes müssen Sie den Theme-Namen und die Anzahl der Partitionen angeben. Die Anzahl der Partitionen bestimmt, wie viele Nachrichten ein Thema gleichzeitig verarbeiten kann.
• Beim Erstellen eines Themas können Sie auch andere Parameter angeben, wie z. B. die Anzahl der Kopien, den Komprimierungstyp usw.
• Nachdem Sie ein Thema erstellt haben, können Sie Nachrichten an das Thema senden.
• Beim Konsumieren von Nachrichten können Sie eine Verbrauchergruppe angeben. Die Verbrauchergruppe bestimmt, welche Verbraucher die Nachrichten im Thema konsumieren können.

Das obige ist der detaillierte Inhalt vonSchnelle Möglichkeit, ein Kafka-Thema zu erstellen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!