Apache Kafka - 工具

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


系统工具

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

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

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

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

  • Mirror Maker − 此工具用于提供一个 Kafka 集群到另一个集群的镜像。

  • Consumer Offset Checker − 此工具显示指定主题集和消费者组的消费者组、主题、分区、偏移量、logSize、所有者。


复制工具

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

  • Create Topic Tool − 这将创建一个具有默认分区数、复制因子的主题,并使用 Kafka 的默认方案进行副本分配。

  • List Topic Tool − 此工具列出给定主题列表的信息。 如果命令行中没有提供主题,该工具会查询 Zookeeper 以获取所有主题并列出它们的信息。 该工具显示的字段是主题名称、分区、领导者、副本、isr。

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