V2EX = way to explore
V2EX 是一个关于分享和探索的地方
Sign Up Now
For Existing Member  Sign In
• 请不要在回答技术问题时复制粘贴 AI 生成的内容
hackingwu
V2EX  ›  程序员

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

  •  
  •   hackingwu ·
    hackingwu · May 23, 2021 · 1136 views
    This topic created in 1801 days ago, the information mentioned may be changed or developed.

    @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.”的字样,这是为啥?

    No Comments Yet
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   5309 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 36ms · UTC 09:21 · PVG 17:21 · LAX 02:21 · JFK 05:21
    ♥ Do have faith in what you're doing.