Apache Kafka 简明教程

Apache Kafka - Tools

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

System Tools

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

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

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

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

  2. Mirror Maker − 此工具用于为一个 Kafka 集群提供镜像另一个 Kafka 集群的功能。

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

Replication Tool

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

  1. Create Topic Tool − 此工具创建了一个具有默认分区数、复制因子的主题并使用 Kafka 的默认方案进行副本分配。

  2. List Topic Tool − 此工具列出给定主题列表的信息。如果命令行中未提供任何主题，则此工具将查询 Zookeeper 以获取所有主题并列出其信息。此工具显示的字段包括主题名称、分区、领导者、副本、isr。

  3. Add Partition Tool − 创建一个主题，必须指定主题的分区数。稍后，当主题的卷增大时，主题可能需要更多分区。此工具有助于为特定主题添加更多分区，还允许手动分配已添加分区的副本。