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
The Spring for Apache Kafka project also provides some assistance by means of the `FilteringMessageListenerAdapter`
1201
1201
class, which can wrap your `MessageListener`.
1202
1202
This class takes an implementation of `RecordFilterStrategy` where you implement the `filter` method to signal
1203
-
that a message is a duplicate and should be discarded.
1204
-
1205
-
A `FilteringAcknowledgingMessageListenerAdapter` is also provided for wrapping an `AcknowledgingMessageListener`.
1206
-
This has an additional property `ackDiscarded` which indicates whether the adapter should acknowledge the discarded record; it is `true` by default.
1203
+
that a message is a duplicate and should be discarded. This has an additional property `ackDiscarded` which indicates
1204
+
whether the adapter should acknowledge the discarded record; it is `false` by default.
1207
1205
1208
1206
When using `@KafkaListener`, set the `RecordFilterStrategy` (and optionally `ackDiscarded`) on the container factory and the listener will be wrapped in the appropriate filtering adapter.
1209
1207
@@ -1228,7 +1226,7 @@ When using `@KafkaListener`, set the `RetryTemplate` (and optionally `recoveryCa
1228
1226
The contents of the `RetryContext` passed into the `RecoveryCallback` will depend on the type of listener.
1229
1227
The context will always have an attribute `record` which is the record for which the failure occurred.
1230
1228
If your listener is acknowledging and/or consumer aware, additional attributes `acknowledgment` and/or `consumer` will be available.
1231
-
For convenience, the `RetryingAcknowledgingMessageListenerAdapter` provides static constants for these keys.
1229
+
For convenience, the `RetryingMessageListenerAdapter` provides static constants for these keys.
1232
1230
See its javadocs for more information.
1233
1231
1234
1232
A retry adapter is not provided for any of the batch <<message-listeners, message listeners>> because the framework has no knowledge of where, in a batch, the failure occurred.
0 commit comments