提前说明：下述所有命令都是需要进入到Kafka服务的的bin目录下执行，即下图所示目录。 

1.查看主题列表

kafka-topics.sh --list --bootstrap-server ip:端口

2.创建主题

如下为创建一个单分区单副本的主题的命令示例：

kafka-topics.sh --create --bootstrap-server ip:端口 --replication-factor 1 --partitions 1 --topic 主题名称

3.查看主题信息 

kafka-topics.sh --bootstrap-server ip:端口 --describe --topic 主题名称

PartitionCount：1表示该主题的分区数

ReplicationFactor：1表示每个分区的副本数，为1的话，表示该分区只有一个分区，即该分区就是leader。

Partition：0表示的是该主题的第几个分区，该标识符从0开始逐次加1递增。

Leader：表示的是领导者分区的位置，即是brokeid的取值（leader 是在给出的所有partitons中负责读写的节点，每个节点都有可能成为leader）

Repicas：表示的是所有副本（包含主分区）的位置集合，可用逗号分隔开。

Isr：位于同步队列的副本（包含主分区）的集合

4.使用消息者接受消息

kafka-console-consumer.sh --bootstrap-server ip:端口 --topic 主题名称 --from-beginning

5.使用生产者发送消息

kafka-console-producer.sh --broker-list ip:端口 --topic 主题名称

6.查看消费组信息

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group 消费组组名

7.删除主题

kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic 主题名称

8.获取版本信息

很遗憾，kafka没有提供直接查看version的命令。

但可以进入kafka/libs文件夹，libs下的文件名称中就包含kafka版本信息，，红框中的2.8.1就是kafka的版本，前面的2.13是Scala版本，如下图所示：