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`
980
980
class, which can wrap your `MessageListener`.
981
981
This class takes an implementation of `RecordFilterStrategy` where you implement the `filter` method to signal
982
-
that a message is a duplicate and should be discarded.
983
-
984
-
A `FilteringAcknowledgingMessageListenerAdapter` is also provided for wrapping an `AcknowledgingMessageListener`.
985
-
This has an additional property `ackDiscarded` which indicates whether the adapter should acknowledge the discarded record; it is `true` by default.
982
+
that a message is a duplicate and should be discarded. This has an additional property `ackDiscarded` which indicates
983
+
whether the adapter should acknowledge the discarded record; it is `false` by default.
986
984
987
985
When using `@KafkaListener`, set the `RecordFilterStrategy` (and optionally `ackDiscarded`) on the container factory and the listener will be wrapped in the appropriate filtering adapter.
988
986
@@ -1006,7 +1004,7 @@ When using `@KafkaListener`, set the `RetryTemplate` (and optionally `recoveryCa
1006
1004
The contents of the `RetryContext` passed into the `RecoveryCallback` will depend on the type of listener.
1007
1005
The context will always have an attribute `record` which is the record for which the failure occurred.
1008
1006
If your listener is acknowledging and/or consumer aware, additional attributes `acknowledgment` and/or `consumer` will be available.
1009
-
For convenience, the `RetryingAcknowledgingMessageListenerAdapter` provides static constants for these keys.
1007
+
For convenience, the `RetryingMessageListenerAdapter` provides static constants for these keys.
1010
1008
See its javadocs for more information.
1011
1009
1012
1010
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