-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Closed
Milestone
Description
Expected Behavior
BackOffHanlder should encapsulate the handling for the next backoff. FailedRecordTracker will use this interface and call handleNextBackoff in recovered method.
Current Behavior
Currently FailedRecordTracker it is tightly coupled with thread sleep. There is no way to inject another behavior.
Context
The idea is to make FailedRecordTracker able to handle the backoff in different ways. In my case I need to pause the listener on XX minutes.
The other solution for me is to copy several classes just to change one line (FailedRecordTracker,FailedRecordProcessor, DefaultAfterRollbackProcessor)