Kubernetes kafka - lagom - Потребитель прервал WakeupException после истечения времени ожидания. Сообщение: ноль - PullRequest
Новая
       46

Kubernetes kafka - lagom - Потребитель прервал WakeupException после истечения времени ожидания. Сообщение: ноль

0 голосов
/ 13 марта 2019

Использование Lagom 1.4.11, Кафка 0.11 Связь с кафкой, кажется, работает, потому что продюсеры что-то произвели. Только у потребителя есть ошибки. 

[WARN] [03/13/2019 19:36:45.937] [gui-akka.kafka.default-dispatcher-8] [akka://gui/system/kafka-consumer-1] Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds
[WARN] [03/13/2019 19:36:50.080] [gui-akka.kafka.default-dispatcher-10] [akka://gui/system/kafka-consumer-1] Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds

похоже, что мой µService не имеет связи с кафкой. У меня есть стручок кафки-0, кафка-зоопарк-0.

Я установил его с 

helm install --name kafka --namespace avalon bitnami/kafka -f values.yaml

Это тот, кто может помочь. Спасибо.

добавлен.

Я узнал, что продюсер создал темы: 

I have no name!@kafka-0:/$ kafka-topics.sh --zookeeper 10.***.21.50:2181 --list
item-issued-topic
topic-item-created

I have no name!@kafka-0:/$ kafka-console-consumer.sh --bootstrap-server kafka-0:9092 --topic topic-item-created --from-beginning
^CProcessed a total of 0 messages

Кажется, что Кафка не хранит сообщения.

...