kafka查看topic列表_kafka阻塞排错步骤
1.首先获取所有的topic的列表bin/kafka-topics.sh --list --zookeeper localhost:21812.查看某一个topic下的log文件和offset是不是一样(下一单之后再次查看有没有变化,应该是log文件和offset同时加1才对,如果不是同时加1说明阻塞)bin/kafka-run-class.sh kafka.tools.ConsumerOffse
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
更多推荐
所有评论(0)