Apache Kafka 工具
Kafka 工具打包在“org.apache.kafka.tools.*.工具分为系统工具和复制工具。
系统工具
可以使用运行类脚本从命令行运行系统工具。语法如下:
bin/kafka-run-class.sh package.class - - options
部分系统工具如下:
Kafka迁移工具: 该工具用于将代理从一个版本迁移到另一个版本。
镜子制造商: 该工具用于提供一个Kafka集群到另一个集群的镜像。
消费者偏移检查器: 该工具显示指定的一组Topics和Consumer Group的Consumer Group、Topic、Partitions、Off-set、logSize、Owner。
复制工具
Kafka 复制是一种高级设计工具。添加复制工具的目的是为了更强的持久性和更高的可用性。下面提到一些复制工具:
创建主题工具: 这会创建一个具有默认分区数、复制因子的主题,并使用 Kafka 的默认方案进行副本分配。
列出主题工具: 这个工具列出了给定主题列表的信息。如果命令行中没有提供主题,该工具会查询 Zookeeper 以获取所有主题并列出它们的信息。该工具显示的字段是主题名称、分区、领导者、副本、isr。
添加分区工具:创建一个topic,必须指定topic的partition个数。稍后,当主题的数量会增加时,主题可能需要更多的分区。此工具有助于为特定主题添加更多分区,还允许手动分配添加的分区的副本。