Kafka トピック作成プロセスのコマンド使用法の詳細な分析

トピックを作成するコマンドの詳細な説明

Kafka のトピックは、関連するメッセージをグループ化する論理的なグループです。トピックには、プロデューサーによってメッセージが書き込まれ、コンシューマーによって読み取られるメッセージを含めることができます。

トピックを作成するコマンドは次のとおりです:

kafka-topics --create --topic <topic-name> --partitions <num-partitions> --replication-factor <replication-factor>

ここで:

• <topic-name> はトピックの名前です。 。
• <num-partitions> は、トピックのパーティションの数です。パーティションはトピックの論理サブセットであり、メッセージはパーティション間で均等に分散されます。
• <replication-factor> は、トピックのレプリカの数です。レプリカはトピックのバックアップであり、トピックの可用性と耐障害性が向上します。

たとえば、3 つのパーティションと 2 つのレプリカを持つ test という名前のトピックを作成するには、次のコマンドを使用できます。

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

コマンド オプション

kafka-topics このコマンドには、トピック作成動作の制御に使用できる他のオプションもいくつか用意されています。これらのオプションは次のとおりです:

• --config <key=value>: テーマの構成プロパティを設定するために使用されます。たとえば、このオプションを使用してトピックの保持ポリシーを設定できます。
• --if-not-exists: トピックがすでに存在する場合は、トピックを作成しないでください。
• --verbose: トピック作成プロセスに関する詳細情報を出力します。

例

トピックの作成例をいくつか示します。

• test という名前のトピックを作成します。 3 つのパーティションと 2 つのレプリカを持つトピック:

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

• 5 つのパーティションと 3 つのレプリカを持つ test という名前のトピックを作成し、トピックの保持ポリシーを ## に設定します。 #delete:

kafka-topics --create --topic test --partitions 5 --replication-factor 3 --config retention.ms=-1

3 つのパーティションと 2 つのコピーを持つ
• test という名前のトピックを作成します。既に存在する場合はトピックを作成しません:

kafka-topics --create --topic test --partitions 3 --replication-factor 2 --if-not-exists

Note

トピックを作成する前に、Kafka クラスターが開始されていることを確認する必要があります。
• トピックは既存の Kafka クラスター内にのみ作成できます。
• 既存のテーマと同じ名前のテーマを作成することはできません。
• テーマ名には文字、数字、アンダースコアのみを含めることができます。
• テーマ名を数字で始めることはできません。
• テーマ名は 255 文字を超えることはできません。

以上がKafka トピック作成プロセスのコマンド使用法の詳細な分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。