kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
Support for max retry backoff time (#750)
Problem
The current max retry back off time is set at a constant of 24 hours. This duration is too long to be practical.
Solution
Making the duration configurable by creating a new property max.retry.duration.ms
. This property has the following features
- It has a default value of 24 hours (just like before).
- It must have a value greater than the value of
retry.backoff.ms
(initial backoff time). If a smaller or equal value is set, a warning message is thrown and the default value is selected instead.
Does this solution apply anywhere else?
- [ ] yes
- [x] no
Test Strategy
Testing done:
- [x] Unit tests
- [ ] Integration tests
- [ ] System tests
- [ ] Manual tests
Release Plan
@sp-gupta Hello. Could you please take a look at this code. Thanks.