Apache Kafka - 工具

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

系统工具

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

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

下面列出了一些系统工具：

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

• 镜像制作器 - 此工具用于将一个 Kafka 集群镜像到另一个集群。

• 消费者偏移量检查器 - 此工具显示指定主题和消费者组的消费者组、主题、分区、偏移量、日志大小和所有者。

复制工具

Kafka 复制是一个高级设计工具。添加复制工具的目的是为了提高持久性和可用性。下面列出了一些复制工具：

• 创建主题工具 - 此工具创建一个主题，其中包含默认数量的分区、复制因子，并使用 Kafka 的默认方案进行副本分配。

• 列出主题工具 - 此工具列出给定主题列表的信息。如果命令行中未提供任何主题，则该工具会查询 ZooKeeper 以获取所有主题并列出其信息。该工具显示的字段包括主题名称、分区、领导者、副本和 ISR。

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