深入解析Kafka主題創建過程的命令用法

建立主題的命令詳解

Kafka中的主題是一個邏輯分組，它將相關的訊息分組在一起。主題可以由生產者向其寫入訊息，也可以由消費者從中讀取訊息。

建立主題的指令是：

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

其中：

• #<topic-name></topic-name> 是主題的名稱。
• <num-partitions></num-partitions> 是主題的分區數。分區是主題的邏輯子集，訊息被均勻地分佈在分區中。
• <replication-factor></replication-factor> 是主題的副本數。副本是主題的備份，它可以提高主題的可用性和容錯性。

例如，要建立名為test 的主題，其中有3 個分割區和2 個副本，可以使用下列指令：

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

命令選項

kafka-topics 指令也提供了一些其他選項，這些選項可以用來控制主題的建立行為。這些選項包括：

• --config <key></key>：用於設定主題的設定屬性。例如，可以使用此選項來設定主題的保留策略。
• --if-not-exists：如果主題已經存在，則不建立主題。
• --verbose：列印有關主題創建過程的詳細資訊。

範例

以下是一些建立主題的範例：

## 建立一個名為
• test#的主題，其中有3 個分割區和2 個副本：

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

建立一個名為
• test 的主題，其中有5 個分割區和3 個副本，並且設定主題的保留策略為delete：

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

#建立一個名為
• test 的主題，其中有3 個分割區和2 個副本，並且如果主題已經存在，則不建立主題：

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

注意

在建立主題之前，您需要確保已經啟動了Kafka 叢集。
• 您只能在已經存在的 Kafka 叢集中建立主題。
• 您無法建立與現有主題同名的主題。
• 主題名稱只能包含字母、數字和底線。
• 主題名稱不能以數字開頭。
• 主題名稱不能超過 255 個字元。

以上是深入解析Kafka主題創建過程的命令用法的詳細內容。更多資訊請關注PHP中文網其他相關文章！