Kafka工具

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

系統工具

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

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

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

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

複製工具

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

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

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

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

0 條評論,你可以發表評論,我們會進行改進
Comment author placeholder