【问题标题】:How to stop Preparing to rebalance group with old generation in Kafka?如何停止准备在 Kafka 中与老年代重新平衡组?
【发布时间】:2021-07-06 19:09:13
【问题描述】:

我将 Kafka 用于我的 Web 应用程序,我在 kafka.log 中找到了以下消息:

[2021-07-06 08:49:03,658] INFO [GroupCoordinator 0]: Preparing to rebalance group qpcengine-group in state PreparingRebalance with old generation 105 (__consumer_offsets-28) (reason: removing member consumer-1-7eafeb56-e6fe-4161-9c88-e69c06a0ab37 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)
[2021-07-06 08:49:03,658] INFO [GroupCoordinator 0]: Group qpcengine-group with generation 106 is now empty (__consumer_offsets-28) (kafka.coordinator.group.GroupCoordinator)

但是,对于一个消费者来说,kafka 就像永远循环一样。 我怎样才能阻止它?

这里是 kafka 日志的图片: enter image description here

【问题讨论】:

    标签: spring-boot apache-kafka kafka-consumer-api spring-kafka


    【解决方案1】:

    如果你只有一个分区,你不需要使用consumer_group 尝试使用Assign(不订阅)

    【讨论】:

    • 感谢您的回答,我想我的问题是通过添加值为10800000的MAX_POLL_INTERVAL_MS_CONFIG属性来解决的,因为处理一个消费者主题所需的时间可以达到3个小时。
    • @learner 你处理单条记录的时间最多需要3个小时?还是针对主题中的全部记录?
    猜你喜欢
    • 2017-05-17
    • 1970-01-01
    • 2019-09-26
    • 2017-09-10
    • 1970-01-01
    • 2019-10-02
    • 1970-01-01
    • 2020-08-04
    • 2021-03-12
    相关资源
    最近更新 更多