在Kafka消费者中,在之前的所有重试都用完后,如何在固定的时间内重试



我在Kafka消费者中使用指数重试。它按预期工作,但我需要添加更多的配置。假设在最大重试次数之后,请求仍然不成功,然后我需要在固定的时间内重试
假设乘数为2,最大重试次数为4,初始重试间隔为1秒然后重试顺序将是
1秒、2秒、4秒、8秒。
第四次尝试后,我需要以固定的间隔重试(比如每10秒重试一次(,直到请求成功
我有什么办法可以做到这一点吗?

假设在RetryTemplate中使用ExponentialBackOffPolicy,则可以设置其maxInterval属性。

如果您使用的是带有ExponentialBackOffSeekToCurrentErrorHandler(这是现代版本的弹簧kafka的首选,以避免重新平衡(,它也具有maxInterval特性。

最新更新