Apache Kafka - 工具

Kafka 工具打包在“org.apache.kafka.tools.*”下。工具分為系統工具和複製工具。

系統工具

可以使用 run class 指令碼從命令列執行系統工具。語法如下：

bin/kafka-run-class.sh package.class - - options

下面列出了一些系統工具：

• Kafka 遷移工具 - 此工具用於將代理從一個版本遷移到另一個版本。

• 映象製作器 - 此工具用於將一個 Kafka 叢集映象到另一個叢集。

• 消費者偏移量檢查器 - 此工具顯示指定主題和消費者組的消費者組、主題、分割槽、偏移量、日誌大小和所有者。

複製工具

Kafka 複製是一個高階設計工具。新增複製工具的目的是為了提高永續性和可用性。下面列出了一些複製工具：

• 建立主題工具 - 此工具建立一個主題，其中包含預設數量的分割槽、複製因子，並使用 Kafka 的預設方案進行副本分配。

• 列出主題工具 - 此工具列出給定主題列表的資訊。如果命令列中未提供任何主題，則該工具會查詢 ZooKeeper 以獲取所有主題並列出其資訊。該工具顯示的欄位包括主題名稱、分割槽、領導者、副本和 ISR。

• 新增分割槽工具 - 建立主題時，必須指定主題的分割槽數。之後，當主題的容量增加時，可能需要為主題新增更多分割槽。此工具有助於為特定主題新增更多分割槽，並允許手動分配新增分割槽的副本。