首頁 >Java >java教程 >創建Kafka主題的快速方法

創建Kafka主題的快速方法

WBOY
WBOY原創
2024-02-01 08:50:06759瀏覽

創建Kafka主題的快速方法

快速建立Kafka主題的步驟

  1. #匯入依賴
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.1.0</version>
</dependency>
  1. 建立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();
    }
}
  1. 運行程式碼
mvn exec:java
  1. 驗證主題是否建立成功
kafka-topics --list --zookeeper localhost:2181

如果看到 my-topic主題,則表示主題建立成功。

注意事項

  • 在建立主題時,需要指定主題名稱和分割區數。分區數決定了主題可以同時處理多少個訊息。
  • 在建立主題時,也可以指定其他參數,例如副本數、壓縮類型等。
  • 在建立主題後,可以向主題發送訊息。
  • 在消費訊息時,可以指定消費群組。消費組決定了哪些消費者可以消費主題中的消息。

以上是創建Kafka主題的快速方法的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn