Package org.springframework.kafka.listener.adapter
Provides classes for adapting listeners.
-
Interface Summary Interface Description BatchToRecordAdapter<K,V> An adapter that adapts a batch listener to a record listener method.BatchToRecordAdapter.Callback<K,V> A callback for each message.RecordFilterStrategy<K,V> Implementations of this interface can signal that a record about to be delivered to a message listener should be discarded instead of being delivered.ReplyHeadersConfigurer A strategy for configuring which headers, if any, should be set in a reply message. -
Class Summary Class Description AbstractDelegatingMessageListenerAdapter<T> Top level class for all listener adapters.AbstractFilteringMessageListener<K,V,T> An abstract message listener adapter that implements record filter logic via aRecordFilterStrategy
.AbstractRetryingMessageListenerAdapter<K,V,T> Base class for retrying message listener adapters.AdapterUtils Utilities for listener adapters.BatchMessagingMessageListenerAdapter<K,V> AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive batches of messages.ConsumerRecordMetadata Used to provide a listener method argument when the user supplies such a parameter.DefaultBatchToRecordAdapter<K,V> The defaultBatchToRecordAdapter
implementation; if the supplied recoverer throws an exception, the batch will be aborted; otherwise the next record will be processed.DelegatingInvocableHandler Delegates to anInvocableHandlerMethod
based on the message payload type.FilteringBatchMessageListenerAdapter<K,V> ABatchMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.FilteringMessageListenerAdapter<K,V> AMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.HandlerAdapter A wrapper for either anInvocableHandlerMethod
orDelegatingInvocableHandler
.InvocationResult The result of a method invocation.MessagingMessageListenerAdapter<K,V> An abstractMessageListener
adapter providing the necessary infrastructure to extract the payload of aMessage
.MessagingMessageListenerAdapter.ReplyExpressionRoot Root object for reply expression evaluation.RecordMessagingMessageListenerAdapter<K,V> AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages.RetryingMessageListenerAdapter<K,V> A retrying message listener adapter forMessageListener
s.