Apache Kafka - 工具

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

系统工具

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

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

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

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

  • Mirror Maker : 此工具用于将一个Kafka群集镜像到另一个Kafka群集.

  • 消费者抵消检查器 : 此工具显示指定的主题和消费者组的消费者组,主题,分区,偏移,logSize,所有者.

复制工具

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

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

  • 列出主题工具 : 此工具列出给定主题列表的信息.如果命令行中未提供任何主题,该工具将查询Zookeeper以获取所有主题并列出其信息.该工具显示的字段是主题名称,分区,领导者,副本,isr.

  • 添加分区工具 : 创建主题,必须指定主题的分区数.稍后,当主题的音量增加时,主题可能需要更多分区.此工具有助于为特定主题添加更多分区,还允许手动复制分配添加的分区.