【发布时间】:2020-01-07 23:46:12
【问题描述】:
我在 linux 服务器上运行了一个 spring-boot 应用程序,它监听了三个主题,起初,它运行良好,但几分钟后,我发现“(Re-)joining group ...”日志,然后只有两个话题已经听过了,其他的听不进去,没有找到错误或者警告日志,不知道怎么解决,就是不知道怎么回事
起初,我想我的消费者配置可能不正确,我设置了 max.poll.interval.ms:5000, max.poll.records:50.but 它不起作用。
在我的听众中,我使用这个注释来听一个主题
@KafkaListener(topics = "xxx")
我想要这三个主题全部作品,但现在只有两个作品
ps:一开始一切正常,几分钟后,(重新)加入组后,一个主题不能正常工作,并且没有错误日志或警告日志
【问题讨论】: