kubernetes-kafka-lagom-consumer在超时后因唤醒异常而中断消息:空

7tofc5zh  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(537)

使用lagom1.4.11,kafka 0.11,与kafka的通信似乎是有效的,因为制作人已经制作了一些东西。只有使用者有错误。

[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

看来我的µ服务与Kafka没有连接。我有一个Kafka-0豆荚,Kafka-0Zookeeper。
我安装了

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似乎没有储存这些信息。

whhtz7ly

whhtz7ly1#

我也遇到了同样的问题,这是解决了看这个文件

./kafka-console-consumer.sh --bootstrap-server kafka-com:9094 --topic test --from-beginning --partition 0

消费者未收到消息

相关问题