库伯内特斯kafka-lagom-消费者在超时后被Wakeup异常中断。消息：null
使用Lagom 1.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
看起来我的µService与kafka没有任何联系。我有一个kafka-0 pod，kafka-zooker-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不存储消息。
共有1个答案
我也遇到了同样的问题，通过查看此文档解决了
./kafka-console-consumer.sh --bootstrap-server kafka-com:9094 --topic test --from-beginning --partition 0
消费者没有收到消息
-
我将python kafka consumer的< code>auto_commit设置为< code>False，我正在手动提交消息。然而，重启后，消费者再次消费来自每个分区的最后一条消息。只有最后一个，不能再多。 这就是所展示的： 不知道为什么会显示滞后，whu当前偏移设置为最后一条消息而不是下一条？当我提交偏移量3时，当前偏移量不应该移动到4吗？ 我提交我使用的每条消息，但是在重启时，它总是
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
我正在尝试让 kafka 消费者获取在 Java 中生成并发布到主题的消息。我的消费者如下。 consumer.java 当我运行上面的代码时，我在控制台中什么也看不到，屏幕后面的java producer程序正在‘AATest’主题下不断地发布数据。另外，在动物园管理员控制台中，当我尝试运行上面的consumer.java时，我得到了以下行 此外，当我运行指向 AATest 主题的单独控制台使用
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
这是一个关于Kafka和信息如何被消费的非常基本的问题，但不幸的是，我在这一点上找不到任何答案。 假设我想过度分区，那么我将得到比消费者多10倍的分区。过度分区是必需的，因为我希望能够扩展(在未来并行处理更多的消息)。 1 个主题分为 1000 个分区，由 100 个使用者使用 =- 我的问题是： > 消息是如何为每个消费者消费的：它是以循环方式完成的吗？如果不是，分发是如何完成的？ 有没有保证消
-
我正在使用这个库来实现节点kafka与消费者暂停和恢复方法来处理背压。我已经创建了一个小演示，我可以在其中和，但问题是在后它停止了消费消息。 这是我的代码。 任何人都可以帮助我，我在恢复消费者时做错了什么？当我启动使用者时，它只接收一条消息，并且在恢复后仍然不消耗任何其他消息。