Apache Kafka 工具

Kafka在“org.apache.kafka.tools。"下打包的工具。 工具分為系統(tǒng)工具和復(fù)制工具。

系統(tǒng)工具

可以使用運(yùn)行類腳本從命令行運(yùn)行系統(tǒng)工具。 語法如下 -

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

下面提到一些系統(tǒng)工具 -

• Kafka遷移工具 - 此工具用于將代理從一個(gè)版本遷移到另一個(gè)版本。

• Mirror Maker - 此工具用于向另一個(gè)Kafka集群提供鏡像。

• 消費(fèi)者偏移檢查器 - 此工具顯示指定的主題和使用者組的消費(fèi)者組，主題，分區(qū)，偏移量，日志大小，所有者。

復(fù)制工具“

Kafka復(fù)制是一個(gè)高級(jí)設(shè)計(jì)工具。 添加復(fù)制工具的目的是為了更強(qiáng)的耐用性和更高的可用性。 下面提到一些復(fù)制工具 -

• 創(chuàng)建主題工具 - 這將創(chuàng)建一個(gè)帶有默認(rèn)分區(qū)數(shù)，復(fù)制因子的主題，并使用Kafka的默認(rèn)方案進(jìn)行副本分配。

• 列表主題工具 - 此工具列出了指定主題列表的信息。 如果命令行中沒有提供主題，該工具將查詢Zookeeper以獲取所有主題并列出它們的信息。 工具顯示的字段是主題名稱，分區(qū)，leader，replicas，isr。

• 添加分區(qū)工具 - 創(chuàng)建主題，必須指定主題的分區(qū)數(shù)。 稍后，當(dāng)主題的卷將增加時(shí)，可能需要用于主題的更多分區(qū)。 此工具有助于為特定主題添加更多分區(qū)，還允許手動(dòng)復(fù)制分配已添加的分區(qū)。