前置条件：已安装kafka程序和zookeeper

1 使用命令前的准备

• 获取zookeeper的地址
  kafka的安装目录：/kafka_2.11-2.1.0

 # cd config/
 # cat server.properties

在这里插入图片描述

2 常用kafka命令

2.1 创建topic

[root@master kafka_2.11-2.1.0]# cd bin/         //进入bin目录
[root@master bin]# sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic lm_ttst --partitions 12 --replication-factor 1            //创建topic

命令讲解：
 参数【zookeeper】：上面在server.properties获取的zookeeper的地址；
 参数【create】：表明要创建的动作；
 参数【topic】：要创建的topic名称；
 参数【partitions】：指定创建topic的分区数；
 参数【replication-factor】：topic的备份数，备份数不能大于kafka集群节点数。

2.2 查询topic是否存在

[root@master bin]# sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --list | grep lm_ttst

命令讲解：
 参数【list】：列出所有的topic；
 参数【grep】：搜索关键字。

2.3 查询topic详细信息

[root@master bin]# sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic lm_ttst --describe

命令讲解：
 参数【describe】：详情。

2.4 删除topic

[root@master bin]# sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic lm_ttst --delete

命令讲解：
 参数【delete】：表明删除动作。

2.5 修改topic分区数

[root@master bin]# sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic lm_ttst --partitions 12

命令讲解：
 参数【alter 】：表明修改动作。
 【partitions】：指定分区数。