问无法监听某些主题(有三个主题，但只找到日志“partitions assigned:[ .]”两个主题)
EN

Stack Overflow用户

提问于 2019-09-05 14:06:11

回答 1查看 38关注 0票数 1

我在linux服务器上运行了一个spring-boot应用程序，它监听了三个主题，一开始，它工作得很好，但几分钟后，我发现“(重新)加入组...”日志，然后只有两个主题被监听，另一个无法监听，找不到错误或警告日志，我不知道如何解决这个问题，只是不知道发生了什么

起初，我认为我的消费者配置可能不正确，我设置了max.poll.interval.ms:5000，max.poll.Records:50。但它不起作用。

在我的监听器中，我使用这个注释来监听一个主题

@KafkaListener(topics = "xxx")

我希望这三个主题都能工作，但现在只有两个工作

ps:一开始，一切正常，仅仅几分钟后，在(重新)加入群后，一个主题无法正常工作，并且没有错误日志或警告日志

回答已采纳

发布于 2019-09-05 22:15:13

(Re-)joining group意味着有另一个消费者加入了同一组，并且发生了重新平衡。Kafka尝试在组成员之间均匀分配分区。这可能是为什么你看不到第三个话题的原因，这是由你的消费者进行调查的。只是因为它去了另一个地方。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/57799287

复制

相似问题

问无法监听某些主题(有三个主题，但只找到日志“partitions assigned:[ .]”两个主题)EN