Skip to content

Add Stateful AfterRollbackProcessor #763

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Closed
garyrussell opened this issue Aug 3, 2018 · 0 comments
Closed

Add Stateful AfterRollbackProcessor #763

garyrussell opened this issue Aug 3, 2018 · 0 comments
Milestone
2.2.M2

Comments

@garyrussell
Copy link
Contributor

Don't re-seek the failing record after some number of failures and provide some strategy that is invoked after retries are exhausted.
@garyrussell garyrussell added this to the 2.2.M2 milestone Aug 3, 2018
@garyrussell garyrussell mentioned this issue Aug 3, 2018
Closed
garyrussell added a commit to garyrussell/spring-kafka that referenced this issue Aug 3, 2018
@garyrussell
spring-projectsGH-763: DefaultAfterRollbackProcessor: recovery
c016e3a 
Resolves spring-projects#763

Add recovery capability to the default ARP.
garyrussell added a commit to garyrussell/spring-kafka that referenced this issue Aug 3, 2018
@garyrussell
spring-projectsGH-763: DefaultAfterRollbackProcessor: recovery
06c46b5 
Resolves spring-projects#763

Add recovery capability to the default ARP.
@garyrussell garyrussell mentioned this issue Aug 3, 2018
Merged
garyrussell added a commit to garyrussell/spring-kafka that referenced this issue Aug 3, 2018
@garyrussell
spring-projectsGH-763: DefaultAfterRollbackProcessor: recovery
6be4045 
Resolves spring-projects#763

Add recovery capability to the default ARP.
garyrussell added a commit to garyrussell/spring-kafka that referenced this issue Aug 3, 2018
@garyrussell
spring-projectsGH-763: DefaultAfterRollbackProcessor: recovery
a9074b6 
Resolves spring-projects#763

Add recovery capability to the default ARP.
artembilan pushed a commit that referenced this issue Aug 7, 2018
@garyrussell @artembilan
GH-763: TX rollback and SeekErrHandler: Recovery
0474eb9 
* GH-763: DefaultAfterRollbackProcessor: recovery

Resolves #763

Add recovery capability to the default ARP.

* Rebase, polishing - PR Comment

* Polishing - refactor code for reuse.

* BiPredicate instead of BiFunction.

* Polishing - PR Comments; also extend functionality to SeekToCurrentErrorHandler
for when not using transactions.

Resolves #766

* Polishing - map the typed list to a wildcard list.

* Polishing - raw types

* Polishing - PR Comments
denis554 added a commit to denis554/spring-kafka that referenced this issue Mar 27, 2019
@denis554
GH-763: TX rollback and SeekErrHandler: Recovery
f3a26c3 
* GH-763: DefaultAfterRollbackProcessor: recovery

Resolves spring-projects/spring-kafka#763

Add recovery capability to the default ARP.

* Rebase, polishing - PR Comment

* Polishing - refactor code for reuse.

* BiPredicate instead of BiFunction.

* Polishing - PR Comments; also extend functionality to SeekToCurrentErrorHandler
for when not using transactions.

Resolves spring-projects/spring-kafka#766

* Polishing - map the typed list to a wildcard list.

* Polishing - raw types

* Polishing - PR Comments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
2.2.M2
Development

No branches or pull requests
1 participant
@garyrussell