Я выполнения ConsumerGroupExample потребитель Кафки, который висит в ожидании сообщенияКафка группа потребителей висит
Оказывается, она висит в ожидании сообщения (ожидание в примере на https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example, на «для (конечного потока KafkaStream: потоки)»
Деталь конфигурации: (а) работает в VMPlayer, операционной система Ubuntu; (б) работает версия Кафка: 0.8.0; (с) работает зоопарк, Кафка, потребитель и производитель на тот же виртуальной машине (убунт/LocalHost); (d) с использованием zookeeper, который поставляется с этой версией Kafka; (e) запуск примера производителя (без изменений, доступен на cwiki.apache.org/confluence/display/KAFKA/); (f) пример группы потребителей (без изменений, ConsumerGroupExample); (г) успешно настроить тему (Кафка создать-теме)
Несколько шагов, которые я взял: (а) неоднократно остановки/запуска зоопарка, Кафка брокеров; (b) имел сообщение о выдаче производителем до начала использования потребителя; (c) имел потребитель, работающий перед производителем (а затем с передачей от производителя сообщений); (d) подтвердил, что потребитель консоли kafka (kafka-console-consumer) работает и может потреблять сообщения, выпущенные производителем; (e) Ошибок/исключений в журналах
Во всех случаях, которые я попытался, потребитель (ConsumerGroupExample) зависает в ожидании сообщения, несмотря на то, что в очереди много сообщений.
Есть ли проблема с конфигурацией, которую мне не хватает?
Любая помощь очень ценится!
Я не знаю, как использовать Кафку, но не главный персонаж Кафки в «Судебном процессе» всю свою жизнь висит и ждет сообщения? Итак, есть какая-то кафкаская ирония, если у вас такая же проблема :) :) – ajb
Я предполагаю, что программа проснулась однажды утром и увидела, что она превратилась в ошибку. – yshavit
Я также столкнулся с той же проблемой. даже после очистки zookeeper и kafka tmp dir все еще сталкиваются с той же проблемой, что потребитель висит. – Shri