使用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似乎没有储存这些信息。
1条答案
按热度按时间whhtz7ly1#
我也遇到了同样的问题,这是解决了看这个文件
消费者未收到消息