Apache Kafka 简明教程

Apache Kafka - Tools

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

Kafka Tool packaged under “org.apache.kafka.tools.*. Tools are categorized into system tools and replication tools.

System Tools

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

System tools can be run from the command line using the run class script. The syntax is as follows −

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

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

Some of the system tools are mentioned below −

  1. Kafka Migration Tool − This tool is used to migrate a broker from one version to an-other.

  2. Mirror Maker − This tool is used to provide mirroring of one Kafka cluster to another.

  3. Consumer Offset Checker − This tool displays Consumer Group, Topic, Partitions, Off-set, logSize, Owner for the specified set of Topics and Consumer Group.

Replication Tool

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

Kafka replication is a high level design tool. The purpose of adding replication tool is for stronger durability and higher availability. Some of the replication tools are mentioned below −

  1. Create Topic Tool − This creates a topic with a default number of partitions, replication factor and uses Kafka’s default scheme to do replica assignment.

  2. List Topic Tool − This tool lists the information for a given list of topics. If no topics are provided in the command line, the tool queries Zookeeper to get all the topics and lists the information for them. The fields that the tool displays are topic name, partition, leader, replicas, isr.

  3. Add Partition Tool − Creation of a topic, the number of partitions for topic has to be specified. Later on, more partitions may be needed for the topic, when the volume of the topic will increase. This tool helps to add more partitions for a specific topic and also allows manual replica assignment of the added partitions.