无法监听某些主题(有三个主题,但只找到两个主题的日志“分配的分区:[.....]”)

can't listener some topics (there is three topic, but only find logs " partitions assigned:[ .....]" for two topics)

我 运行 spring-boot 应用程序在 linux 服务器上,它听了三个主题,起初,它运行良好,但几分钟后,我发现“(重新-)joining group ...”日志,然后只听了两个主题,另一个听不到,没有错误或警告日志可以找到,我不知道如何解决这个问题,只是不知道发生了什么

起初,我想也许我的消费者配置不正确,我设置了 max.poll.interval.ms:5000,max.poll.records:50.but 它不起作用。

在我的听众中,我使用这个注解来听一个话题

@KafkaListener(topics = "xxx")

我想要这三个主题都有效,但现在只有两个有效

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

(Re-)joining group 意味着有另一个消费者加入同一个组并且发生了重新平衡。 Kafka 尝试在组成员之间平均分配分区。这可能是您看不到该消费者要投票的第三个主题的原因。就因为它去了另一个。

在此处查看有关再平衡的更多信息: