ホームページ  >  記事  >  Java  >  Kafka トピックを簡単に作成する方法

Kafka トピックを簡単に作成する方法

WBOY
WBOYオリジナル
2024-02-01 08:50:06748ブラウズ

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 topic は、トピックが正常に作成されたことを意味します。

  • トピックを作成するときは、トピック名とパーティション数を指定する必要があります。パーティションの数によって、トピックが同時に処理できるメッセージの数が決まります。
  • トピックを作成するときは、コピー数や圧縮タイプなどの他のパラメータも指定できます。
  • トピックを作成した後、トピックにメッセージを送信できます。
  • メッセージを消費するときに、コンシューマ グループを指定できます。コンシューマ グループは、どのコンシューマがトピック内のメッセージを消費できるかを決定します。

以上がKafka トピックを簡単に作成する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。