时间戳

首页 > 解决方案 > 消费者离开消费群体的可能原因是什么？

spring-kafka - 消费者离开消费群体的可能原因是什么？

问题描述

我正在努力找出问题所在，消费者被阻止的原因是什么。

问题是消费者在一段时间后停止（大约 4:52 秒）但是能够消费消息并能够处理。

据我了解，消费者停止的原因是，消费者将无法在 max.poll.interval.ms 内提交偏移量（处理时间超过 max.poll.interval.ms）。

还有其他原因吗？

这是我的基本消费者属性：

max.poll.records = 2
auto.offset.reset = latest
max.poll.interval.ms = 300000
idle.poll.interval = 60000 (between two polls)
no.of.consumers =1
consumer.group.id = test2
listener.auto.start = true

我在日志中看到一些语句 -
收到用户唤醒，引发 WakeupException 以响应用户唤醒，执行 onLeavePrepare 并生成生成

有人可以帮忙吗？

注意：我们是事件中心的消费者，在这个连接上我们看到了这个问题。但是当我们连接到 Kafka 时，我们没有看到任何问题。

@Gary，你能帮忙吗？

标签： spring-kafka

解决方案

看来kafka配置方面，一切看起来都很好。我们发现的问题是在 docker pods 上，没有发送 pod 的运行状况。因为 livenessProbe - 端口与应用程序配置端口不同（我错误地硬编码了不同的端口）。无论如何感谢这个论坛！！！！

推荐阅读