Kafka工具

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

系統工具

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

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

下面提到了一些系統工具 -

• Kafka遷移工具 - 此工具用於將代理從一個版本遷移到另一個版本。
• Mirror Maker - 此工具用於將一個Kafka叢集映象到另一個。
• 消費者偏移量檢查器 - 此工具顯示指定的一組主題和使用者組的消費者組，主題，分割區，偏移量，紀錄檔大小，所有者。

複製工具

Kafka複製是一個高層次的設計工具。 新增複製工具的目的是提供更強的耐用性和更高的可用性。 下面提到了一些複製工具 -

• 建立主題工具 - 這會建立一個包含預設分割區數量，複製因子的主題，並使用Kafka的預設方案執行副本分配。

• 列表主題工具 - 此工具列出給定主題列表的資訊。 如果在命令列中沒有提供主題，該工具將查詢Zookeeper以獲取所有主題並列出它們的資訊。 該工具顯示的欄位是主題名稱，分割區，領導，副本，isr。

• 新增分割區工具 - 建立主題時，必須指定主題的分割區數量。 稍後，當話題量增加時，話題可能需要更多的分割區。 此工具有助於為特定主題新增更多分割區，還可以手動新增分割區的副本分配。