【问题标题】:can't listener some topics (there is three topic, but only find logs " partitions assigned:[ .....]" for two topics)无法监听某些主题(有三个主题,但只能找到两个主题的日志“分区分配:[.....]”)
【发布时间】: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:一开始一切正常,几分钟后,(重新)加入组后,一个主题不能正常工作,并且没有错误日志或警告日志

【问题讨论】:

    标签: spring-boot spring-kafka


    【解决方案1】:

    (Re-)joining group 表示有另一个消费者加入同一个组并发生了重新平衡。 Kafka 尝试在组成员之间平均分配分区。这可能是您看不到消费者要轮询的第三个主题的原因。只是因为它已经去了另一个。

    在此处查看有关重新平衡的更多信息:What does "Rebalancing" mean in Apache Kafka context?

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-05-27
      • 2015-03-05
      • 1970-01-01
      • 2020-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多