kafka初学者必须知道的常用命令分享

1、启动kafkaserver 。进入安装目录，在安装目录的bin路径上，使用下图的命令进行启动。需要说明的是你需要在config目录下配置好server.properties 这个文件。关于这个文件的配置我在这里就不多介绍了，你可以上去kafka的官网或者其他网站上理解各个参数的使用。

3、创建Topic 。关于创建主题，大家也可以去了解kafka的工作原理，创建主题的命令可用下面的命令操作。bin/kafk锾攒揉敫a-create-topic.sh--topic<topic>指定topic的名字--zookeeper<urls>指定zookeeper的连接地址，格式为host:port--partition<integer>指定partition的数量，默认为1--replica<integer>指定partition的备份数，默认为1--replica-assignment-list 手动分配replica到broker上，格式为<broker_id_for_part1_replica1:broker_id_for_part1_replica2,broker_id_for_part2_replica1:broker_id_for_part2_replica2,...>下图为创建主题的两个例子。

5、重新分配partition ，可以采用下面的命令：bin/kafka-reassign-partit足毂忍珩ions.sh--zookeeper<urls>指定zookeeper的连接地址，格式host:port--broker-list<brokerlist>指定partition需要重新分配到哪些节点，格式为”0,1,2”--topics-to-move-json-file<topicstoreassignjsonfilepath> 指定JSON文件的地址，文件内容是需要重新分配的topic列表。这个选项和manual-assignment-json-file选项需要指定其中的一个。文件内容的格式为{"topics":[{"topic":"test"},{"topic":"test1"}],"version":1}--manual-assignment-json-file<manualassignmentjsonfilepath>指定JSON文件的地址，文件内容是手动分配的策略。这个选项和topics-to-move-json-file选项需要指定其中的一个。文件内容的格式为{"partitions":[{"topic":"test","partition":1,"replicas":[1,2,3]}],"version":1}--status-check-json-file<partitionreassignmentjsonfilepath>指定JSON文件的地址，文件内容是partition和partition需要分配到的新的replica的列表。这个JSON文件可以从模拟执行的结果得到。--execute如果使用这个选项，那么会执行真实的重新分配分区的操作。如果不指定这个选项，默认会进行模拟执行。例子如下图所示。

7、手动均衡Topic，让partition选择preferredreplica作为leaderbin/kafka-preferred-replica-election.sh--zookeeper指定zookeeper的连接地址，格式host:port--path-to-json-file指定需要重新进行leader选举的partition列表文件所在的地址，文件内容的格式为{“partitions”:[{“topic”:“test”,“partitions”:1},{“topic”:“test”, “partitions”:2}]}默认值为所有存在的partition 。例子如下图所示。

9、查看Consumer的消费和积压信息。命令格式如下：bin/kafka-run-class.shkafka.tools.ConsumerOffsetChecker--broker-info显示broker的信息--group<groupname>必须，指定consumergroup的名字--topic<topic>指定topic的名字--zkconnect<urls>必须，指定zookeeper的连接地址，格式host:port例子如下图所示。