我正在执行Kafka的ConsumerGroupExample使用者，它会挂起等待消息
它似乎正在等待消息（在https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example等待示例，在"for (final KafkaStream stream : streams)"
配置细节：（a）在VMPlayer，Ubuntu操作系统中运行; （b）运行Kafka版本：0.8.0; （c）在同一个VM上运行zookeeper，kafka，consumer和producer（ubuntu / localhost）; （d）使用与此版本的Kafka捆绑在一起的zookeeper; （e）运行 生产环境 者示例（未更改，可在cwiki.apache.org/confluence/display/KAFKA/获得）; （f）运行Consumer Group示例（不变，ConsumerGroupExample）; （g）成功设置主题（kafka-create-topic）
我采取的一些步骤：（a）反复停止/启动动物园管理员， Kafka 经纪人; （b） 生产环境 者在消费者开始前发出消息; （c）让消费者在 生产环境 者之前运行（然后让 生产环境 者发送消息）; （d）证实kafka的控制台消费者（kafka-console-consumer）工作并且可以消费 生产环境 者发出的消息; （e）日志中没有错误/例外
在我尝试的所有情况下，尽管有证据表明队列中有很多消息，但消费者（ConsumerGroupExample）仍在等待消息 .
是否存在我缺少的配置问题？
任何帮助深表感谢！
1 回答
不确定问题的根本原因是什么，但是当我清除了zookeeper和kafka数据（默认情况下在/ tmp中）并重新启动了zookeeper和kafka经纪人时，它已得到修复