Kafka工具

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

系統工具

系統工具可以使用run class腳本從命令行運行。 語法如下 -

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

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

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

複製工具

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

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

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

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