Kafka工具打包在“ org.apache.kafka.tools。*”下。工具分为系统工具和复制工具。

系统工具

可以使用运行类脚本从命令行运行系统工具。语法如下-

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

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

• Kafka迁移工具-此工具用于将代理从一个版本迁移到另一个版本。

• Mirror Maker-此工具用于将一个Kafka群集镜像到另一个。

• 消费者偏移检查器-此工具显示指定主题和消费者组的消费者组，主题，分区，偏移，logSize，所有者。

复制工具

Kafka复制是高级设计工具。添加复制工具的目的是为了实现更高的持久性和更高的可用性。下面提到了一些复制工具-

• 创建主题工具-这将创建一个具有默认分区数，复制因子的主题，并使用Kafka的默认方案进行副本分配。

• 列表主题工具-此工具列出给定主题列表的信息。如果命令行中未提供主题，该工具将查询Zookeeper以获取所有主题并列出其信息。该工具显示的字段是主题名称，分区，领导者，副本，isr。

• 添加分区工具-创建主题，必须指定主题的分区数。稍后，当主题的数量将增加时，主题可能需要更多的分区。该工具有助于为特定主题添加更多分区，并且还允许对添加的分区进行手动副本分配。