我在Kafka消费者中使用指数重试。它按预期工作,但我需要添加更多的配置。假设在最大重试次数之后,请求仍然不成功,然后我需要在固定的时间内重试
假设乘数为2,最大重试次数为4,初始重试间隔为1秒然后重试顺序将是
1秒、2秒、4秒、8秒。
第四次尝试后,我需要以固定的间隔重试(比如每10秒重试一次(,直到请求成功
我有什么办法可以做到这一点吗?
假设在RetryTemplate
中使用ExponentialBackOffPolicy
,则可以设置其maxInterval
属性。
如果您使用的是带有ExponentialBackOff
的SeekToCurrentErrorHandler
(这是现代版本的弹簧kafka的首选,以避免重新平衡(,它也具有maxInterval
特性。