java - 卡夫卡消费群挂起

Question

我正在执行挂起的Kafka的ConsumerGroupExample消费者，等待消息

似乎它正在挂起等待消息（例如，在https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example处，在“ for（最终KafkaStream流：流）”处等待

配置详细信息：
（a）在Ubuntu操作系统VMPlayer中运行；
（b）运行Kafka版本：0.8.0；
（c）在同一虚拟机（ubuntu / localhost）上运行zookeeper，kafka，消费者和生产者；
（d）使用与该版本的Kafka捆绑在一起的zookeeper；
（e）运行Producer示例（未更改，可从cwiki.apache.org/confluence/display/KAFKA/获得）；
（f）运行Consumer Group示例（不变，ConsumerGroupExample）；
（g）成功设置一个主题（kafka-create-topic）

我已采取的一些步骤：
（a）反复停止/启动动物园管理员，卡夫卡经纪人；
（b）生产者是否在消费者开始之前发布了消息；
（c）消费者在生产者之前运行（然后让生产者发送消息）；
（d）验证kafka的控制台使用者（kafka-console-consumer）可以工作并且可以使用生产者发布的消息；
（e）日志中没有错误/异常

在所有尝试的情况下，尽管有证据表明队列中有很多消息，但使用者（ConsumerGroupExample）挂起等待消息。

我是否缺少配置问题？

任何帮助深表感谢！

Answer 1

不知道问题的根本原因是什么，但是当我清除了zookeeper和kafka数据（默认为/ tmp）并重新启动了zookeeper和kafka代理后，此问题已得到解决。