Add BackOffHandler to FailedRecordTracker #2262
Milestone
Comments
|
PR : #2263 |
garyrussell
pushed a commit
to garyrussell/spring-kafka
that referenced
this issue
Jun 27, 2022
With default implementation (suspend thread) and container pausing/resuming implementation. init commit adding default impl changes add Apache licence pr fix style fixes added ListenerContainerPauseService
garyrussell
added a commit
to garyrussell/spring-kafka
that referenced
this issue
Jun 27, 2022
garyrussell
pushed a commit
that referenced
this issue
Jun 27, 2022
With default implementation (suspend thread) and container pausing/resuming implementation. init commit adding default impl changes add Apache licence pr fix style fixes added ListenerContainerPauseService
garyrussell
added a commit
that referenced
this issue
Jul 11, 2022
MLC can be null. Other Sonar fixes.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
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)
The text was updated successfully, but these errors were encountered: