使用 spring retryable 超过 max.poll.interval.ms 竟然没有被移出 consumer group
source link: https://www.v2ex.com/t/778739
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
使用 spring retryable 超过 max.poll.interval.ms 竟然没有被移出 consumer group
hackingwu · hackingwu · 10 小时 5 分钟前 · 112 次点击@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.”的字样，这是为啥？
Recommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK