Kubernetes kafka-lagom-使用者在超时后被WakeupException中断。讯息：空

Question

使用Lagom 1.4.11，kafka 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与kafka没有连接。我有一个kafka-0吊舱，kafka-zookeeper-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
似乎kafka没有存储消息。

使用Lagom 1.4.11，kafka 0.11与kafka的通信似乎有效，因为生产者已经生产了一些东西。只有消费者有错误。 [WARN] [03/13/2019 19：36：45.937] [gui-akka.kafka ....

Answer 1

我也遇到了同样的问题，通过查看此文档可以解决此问题