|
为了方便管理和使用，Kafka提供了很多管理脚本，Linux版本的管理脚本存放在$KAFKA_ HOME/bin目录下(在$KAFKA_ HOME/bin/windows 目录下可以找到对应的Windows脚本)。下面先来介绍常用脚本的功能。 kafka-server-start脚本:启动Kafka Server。 kafka-server-stop脚本:停止Kafka Stop。 kafka-opics脚本:负责Topic相关操作，例如，创建Topic,查询Topic名称以及详细信息，增加分区的数量并完成新增分区的副本等。 kafka-preferred-replica-election脚本:触发指定的分区进行“优先副本”选举，这样可以让分区Leader副本在集群中分布得更均匀。 katka-reassgn-patitions脚本:主要有三个功能，一是生成副本迁移的方案，二是触发副本迁移操作，即将迁移方案写入到ZooKeeper中，从而触发PartitionsReassignedListener处理，三是检测指定分区的副本迁移是否已完成。 kafka-console-producer脚本:控制台版本的生产者，我们可以在控制台中输人消息的key和value,由此脚本封装成消息并发送给服务端。 kafka-console-consumer脚本:控制台版本的消费者，我们可以通过参数指定订阅的Topic, 此脚本会从服务端拉取消息并输出到控制台。 kafka-consumer-groups脚本: 有两个主要的功能，一是查询当前所有Consumer Group,二是获取指定Consumer Group的详细信息。 DumpLogSegments:可由kafka-run-class脚本运行，主要负责解析输出指定的日志文件和索引文件中的内容，另外还可以实现索引文件的验证。 kafka-producer-perf-test脚本:负责测试生产者的各项性能指标。 kafka-consumer-perf-test脚本:负责测试消费者的各项性能指标。 kafka-mirrir -maker脚本:实现了数据在多个集群的同步，可用于Kafka集群的镜像制作。 |
|
|
