一般的に使用される Kafka トピック作成コマンド

1. コマンド ラインを使用してトピックを作成します

kafka-topics --create --topic test --partitions 3 --replication-factor 2

このコマンドは、3 つのパーティションとレプリケーションを持つ「test」という名前のトピックを作成します。係数 2。これは、冗長性と高可用性を確保するために、データが 2 つの異なるブローカー上で 3 回複製されることを意味します。

2. Java API を使用してトピックを作成する

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient adminClient = AdminClient.create(props);

NewTopic topic = new NewTopic("test", 3, (short) 2);
adminClient.createTopics(Arrays.asList(topic));

このコードは、3 つのパーティションと 2 つのレプリケーション要素を持つ「test」という名前のトピックを作成します。

3. Python API を使用してトピックを作成する

from kafka import KafkaAdminClient

admin_client = KafkaAdminClient(bootstrap_servers="localhost:9092")

topic_list = [
    kafka.admin.NewTopic(name="test", num_partitions=3, replication_factor=2)
]

admin_client.create_topics(new_topics=topic_list, validate_only=False)

このコードは、3 つのパーティションと 2 つのレプリケーション要素を持つ「test」という名前のトピックを作成します。

4. REST API を使用してトピックを作成する

curl -X POST -H "Content-Type: application/json" -d '{"name": "test", "partitions": 3, "replication_factor": 2}' http://localhost:8083/topics

このコマンドは、3 つのパーティションと 2 つのレプリケーション要素を持つ「test」という名前のトピックを作成します。

5. Kafka UI を使用してトピックを作成する

1. http://localhost:8083 で Kafka UI を開きます。
2. [テーマ]タブをクリックします。
3. 「テーマの作成」ボタンをクリックします。
4. [名前]フィールドにトピックの名前を入力します。
5. 「パーティション数」フィールドにパーティションの数を入力します。
6. 「レプリケーション係数」フィールドに、レプリケーション係数を入力します。
7. 「作成」ボタンをクリックします。

トピックが作成され、トピック リストに表示されます。

その他のオプション

上記の方法に加えて、次のオプションを使用してトピックを作成することもできます。

• Use [Kafka] REST プロキシ] (https://kafka.apache.org/documentation/#rest_proxy)
• [Kafka Python パッケージ](https://github.com/dpkp/kafka-python)
# を使用する##[Kafka Go パッケージ](https://github.com/Shopify/sarama)を使用します
• [Kafka Node.js パッケージ](https://github.com/segmentio/kafka-node)を使用します

注意事項

テーマを作成するときは、テーマ名が一意であることを確認する必要があります。
• パーティションの数とレプリケーション係数がアプリケーションのニーズと互換性があることも確認する必要があります。
• 多数のパーティションを含むトピックを作成すると、パフォーマンスの問題が発生する可能性があります。
• レプリケーション係数が大きいトピックを作成すると、ストレージのオーバーヘッドが増加する可能性があります。

以上が一般的に使用される Kafka トピック作成コマンドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。