1、在kafka查看主题__consumer_offsets的情况
$kafka_home/bin/kafka-topics.sh --describe --zookeeper hostname:2181 --topic __consumer_offsets
显示图片的结果,就是消费者的偏移存储有问题。
2、在zookeeper中删除主题__consumer_offsets
cd $zookeeper_home/bin
#进入zookeeper命令行环境
./zkCli.sh
#显示节点
ls /brokers/topics
#删除__consumer_offsets节点
rmr /brokers/topics/__consumer_offsets
3、重启kafka,可以在kafka中看到重新生成__consumer_offsets主题,并且改主题的leader不是-1。
4、使用kafka-consumer-console.sh测试消费消息。
标签:__,消费,消费者,offsets,topics,zookeeper,kafka,consumer From: https://www.cnblogs.com/chubbyData/p/17219459.html