zk和kafka之间的认证失败了,检查下kafka和zk之间的认证。
谢谢你了,哥,后续我再慢慢研究下。暂时我就通过命令标记删除,这样试了下过1分钟就自动删除掉了,缺点就是必须得保证生产的数据,消费者都拉完了,因为一下子全删完了。
./kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic gpsdata
你失败的原因可能是__consumer_offsets是个单个副本,这个topic存储的是kafka消费者的offset。
另外,关键有问题的topic的描述你没有贴,你用kafka自动的命令进行消费和生产也ok的时候,在去进行代码测试。
## 查询集群描述
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181
## 查询集群描述(新)
bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic foo --describe
命令来自:kafka命令大全