メッセージを待ってハングする 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 (ubuntu/localhost) で Zookeeper、kafka、consumer、および Producer を実行する。(d) このバージョンの Kafka にバンドルされている Zookeeper を使用する。(e) Producer の実行例 (変更なし、cwiki.apache.org/confluence/display/KAFKA/ で入手可能); (f) 実行中のコンシューマ グループの例 (変更なし、ConsumerGroupExample)。(g) トピックのセットアップに成功しました (kafka-create-topic)
私が行ったいくつかの手順: (a) 飼育係、kafka ブローカーを繰り返し停止/開始しました。(b) コンシューマが開始する前にプロデューサがメッセージを発行していた。(c) プロデューサの前にコンシューマを実行する (そして、プロデューサにメッセージを送信させる)。(d) kafka のコンソール コンシューマー (kafka-console-consumer) が機能し、プロデューサーによって発行されたメッセージを消費できることを確認しました。(e) ログにエラー/例外がない
私が試したすべてのケースで、キューに多くのメッセージがあるという証拠にもかかわらず、コンシューマー (ConsumerGroupExample) はメッセージを待ってハングします。
見落としている構成上の問題はありますか?
どんな助けでも大歓迎です！