Apache Kafka：工具集

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

系统工具

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

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

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

  Kafka迁移工具：该工具用于将代理从一个版本迁移到另一个版本。

  镜像生成器：该工具用于将一个Kafka集群镜像到另一个Kafka集群。

  消费者偏移检查器：此工具显示特定主题集和使用者组的使用者组、主题、分区、偏移、日志大小、所有者。

复制工具

  Kafka复制是一个高级设计工具。添加复制工具的目的是提高耐用性和可用性。下面提到了一些复制工具。

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

  列出主题工具:该工具列出给定主题列表的信息。如果命令行中没有提供主题，该工具会查询动物园管理员以获取所有主题并列出相关信息。该工具显示的字段是主题名称、分区、领导者、副本、isr。

  添加分区工具:创建主题时，必须指定主题的分区数量。稍后，当主题的容量增加时，主题可能需要更多的分区。此工具有助于为特定主题添加更多分区，还允许手动分配添加的分区的副本。