You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/asciidoc/kafka.adoc
+10Lines changed: 10 additions & 0 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -5081,6 +5081,16 @@ The container commits any pending offset commits before calling the error handle
5081
5081
5082
5082
If you are using Spring Boot, you simply need to add the error handler as a `@Bean` and Boot will add it to the auto-configured factory.
5083
5083
5084
+
[[backoff-handlers]]
5085
+
===== Back Off Handlers
5086
+
5087
+
Error handlers such as the <<default-eh>> use a `BackOff` to determine how long to wait before retrying a delivery.
5088
+
Starting with version 2.9, you can configure a custom `BackOffHandler`.
5089
+
The default handler simply suspends the thread until the back off time passes (or the container is stopped).
5090
+
The framework also provides the `ContainerPausingBackOffHandler` which pauses the listener container until the back off time passes and then resumes the container.
5091
+
This is useful when the delays are longer than the `max.poll.interval.ms` consumer property.
5092
+
Note that the resolution of the actual back off time will be affected by the `pollTimeout` container property.
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/asciidoc/whats-new.adoc
+10-1Lines changed: 10 additions & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -6,4 +6,13 @@ For changes in earlier version, see <<history>>.
6
6
[[x29-kafka-client]]
7
7
==== Kafka Client Version
8
8
9
-
This version requires the 3.1.0 `kafka-clients`
9
+
This version requires the 3.2.0 `kafka-clients`
10
+
11
+
[[x29-eh changes]]
12
+
==== Error Handler Changes
13
+
14
+
The `DefaultErrorHandler` can now be configured to pause the container for one poll and use the remaining results from the previous poll, instead of seeking to the offsets of the remaining records.
15
+
See <<default-eh>> for more information.
16
+
17
+
The `DefaultErrorHandler` now has a `BackOffHandler` property.
0 commit comments