本文主要介绍一些常见的kafka命令使用，方便一些日常kafka问题排查，本文采用的kafka集群三个节点集群（node1:19092,node2:19092,node3:19092）

常用命令

创建topic（在kafka bin目录执行）

./kafka-topics.sh --create --bootstrap-server node1:19092,node2:19092,node3:19092 --replication-factor 1 --partitions 3 --topic test-topic

创建topic时可以指定副本数和partition

删除topic

./kafka-topics.sh --delete --bootstrap-server node1:19092,node2:19092,node3:19092 --topic test-topic

查看topic列表

./kafka-topics.sh --list --bootstrap-server node1:19092,node2:19092,node3:19092

生产者操作：

 ./kafka-console-producer.sh --broker-list node1:19092,node2:19092,node3:19092 --topic my-kafka-topic

消费者操作：

 ./kafka-console-consumer.sh node1:19092,node2:19092,node3:19092 --topic my-kafka-topic

如果需要查看topic的详细信息，需要使用describe命令

./kafka-topics.sh --describe --bootstrap-server node1:19092,node2:19092,node3:19092 --topic test-topic

若不指定topic，则查看所有topic的信息

./kafka-topics.sh --describe --bootstrap-server node1:19092,node2:19092,node3:19092

查看消费位置

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --bootstrap-server node1:19092,node2:19092,node3:19092 --group testGroup

修改分区数

./kafka-topics.sh --bootstrap-server node1:19092,node2:19092,node3:19092 --alter --partitions 2 --topic test

kafka查看topic数据消费情况

1：查询消费数据，必须要指定组。查看kafka组使用以下命令

./kafka-consumer-groups.sh --bootstrap-server node1:19092,node2:19092,node3:19092 --list 

2：查看消费情况

./kafka-consumer-groups.sh --bootstrap-server node1:19092,node2:19092,node3:19092 --describe --group groupname

查看topic下面各个parition里offset情况，查看topic消费进度

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node1:19092,node2:19092,node3:19092 --topic test-topic --time -1

-1表示查询test各个分区当前最大的消息位移值(注意，这里的位移不只是consumer端的位移，而是指消息在每个分区的位置)

如果你要查询曾经生产过的最大消息数，那么只运行上面这条命令然后把各个分区的结果相加就可以了。

但如果你需要查询当前集群中该topic的消息数，那么还需要运行下面这条命令：

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node1:19092,node2:19092,node3:19092 --topic s1mmetest --time -2

-2表示去获取当前各个分区的最小位移。之后把运行第一条命令的结果与刚刚获取的位移之和相减就是集群中该topic的当前消息总数。

如有错误，欢迎指正，相互学习，共同进步。