V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
hackingwu
V2EX  ›  程序员

使用 spring retryable 超过 max.poll.interval.ms 竟然没有被移出 consumer group

  •  
  •   hackingwu ·
    hackingwu · 2021-05-23 23:36:52 +08:00 · 766 次点击
    这是一个创建于 1134 天前的主题,其中的信息可能已经有所发展或是发生改变。

    @Retryable( maxAttempts = 99, backoff = @Backoff(delay = 1000L, multiplier = 1)) @KafkaListener(id="tc1", containerFactory = "tc1", topics = "s") public void consume(ConsumerRecord<String, String> record, Acknowledgment acknowledgment){ } 我这段代码使用了 Retryable,也就是一个方法执行的耗时 可能是 99s 至少,我的 max.poll.interval.ms 设成 3s,返回由于太久没有 ack,超过 max.poll.interval.ms ,被移出 consumer group 。但是我把 interval 设到 10s 以上,竟然就没有看到“This member will leave the group because consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records.”的字样,这是为啥?

    目前尚无回复
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3313 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 32ms · UTC 10:44 · PVG 18:44 · LAX 03:44 · JFK 06:44
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.