卡夫卡消費羣掛

我執行的哪個掛起等待消息卡夫卡消費羣掛

看來它是掛在等待一個消息（在https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example例如，在等待，在「對於（最終KafkaStream流：流）」卡夫卡的ConsumerGroupExample消費

配置詳情：（a）以VMPlayer，Ubuntu的操作系統運行; （b）中運行卡夫卡版本：0.8.0; （c）中運行動物園管理員，卡夫卡，消費者和生產者在同一VM（ubuntu的/本地主機）; （d）使用與此版本的Kafka捆綁在一起的動物園管理員; （e）運行Producer示例（不變，可在cwiki.apache.org/confluence/display/KAFKA/處獲得）; （f）運行使用者羣組示例（不變，ConsumerGroupExample）; （g）成功設置了一個主題（kafka-create-topic）

我採取的一些步驟：（a）反覆停止/啓動zookeeper，kafka brokers; （b）生產者在消費者開始之前發出消息; （c）消費者在生產者之前運行（然後讓生產者發送消息）; （d）證實kafka的控制檯消費者（kafka-console-consumer）工作並且可以使用生產者發佈的消息; （e）日誌中沒有錯誤/例外

在所有我嘗試過的情況下，消費者（ConsumerGroupExample）掛起等待消息，儘管證據表明隊列中有很多消息。

是否有配置問題，我錯過了？

任何幫助非常感謝！

來源

2014-01-19 Eric Broda

我不知道如何使用卡夫卡，但卡夫卡在「審判」中的主角並沒有花費他一生的時間來等待消息？所以如果你遇到同樣的問題，就會出現某種卡夫卡式的反諷:) :) – ajb

我想程序在一天早上醒來，看到它變成了一個bug。 – yshavit

我也面臨同樣的問題。即使在清理zookeeper和kafka tmp dir之後仍然面臨着消費者掛起的相同問題。 – Shri

不知道根本原因是問題是什麼，但是當我清除了動物園管理員和卡夫卡的數據（默認情況下爲/ tmp）並重新啓動兩個飼養員和卡夫卡經紀人它是固定

來源

2014-01-21 00:08:40

卡夫卡消費羣掛

回答

相關問題