V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
• 请不要在回答技术问题时复制粘贴 AI 生成的内容
hackingwu
V2EX  ›  程序员

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

  •  
  •   hackingwu ·
    hackingwu · 2021 年 5 月 23 日 · 1096 次点击
    这是一个创建于 1776 天前的主题,其中的信息可能已经有所发展或是发生改变。

    @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   ·   Solana   ·   2556 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 39ms · UTC 09:12 · PVG 17:12 · LAX 02:12 · JFK 05:12
    ♥ Do have faith in what you're doing.