1.首先获取所有的topic的列表

bin/kafka-topics.sh --list --zookeeper localhost:2181

2.查看某一个topic下的log文件和offset是不是一样（下一单之后再次查看有没有变化，应该是log文件和offset同时加1才对，如果不是同时加1说明阻塞）

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group cxx_system --topic cxx_subs_topic

3.如果发生阻塞可以通过重启kafka来解决

首先关闭zookeeper，再关闭kafka，然后开启zookeeper，在开启kafka（注意顺序和集群的时候，如果是集群的情况记得都要开启）

其他说明：

查看某一个topic的状态

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic某一个名字

获取关于某一个topic的所有的记录（注意：有可能获取获取不到值，是因为offset是非法排序的所以获取不到值）

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic topic某一个名字 --from-beginning