@NonNullApi

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 a RecordFilterStrategy.
AbstractRetryingMessageListenerAdapter<K,V,T>	Base class for retrying message listener adapters.
AdapterUtils	Utilities for listener adapters.
BatchMessagingMessageListenerAdapter<K,V>	A MessageListener adapter that invokes a configurable HandlerAdapter; 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 default BatchToRecordAdapter implementation; if the supplied recoverer throws an exception, the batch will be aborted; otherwise the next record will be processed.
DelegatingInvocableHandler	Delegates to an InvocableHandlerMethod based on the message payload type.
FilteringBatchMessageListenerAdapter<K,V>	A BatchMessageListener adapter that implements filter logic via a RecordFilterStrategy.
FilteringMessageListenerAdapter<K,V>	A MessageListener adapter that implements filter logic via a RecordFilterStrategy.
HandlerAdapter	A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.
InvocationResult	The result of a method invocation.
KafkaBackoffAwareMessageListenerAdapter<K,V>	A AcknowledgingConsumerAwareMessageListener implementation that looks for a backoff dueTimestamp header and invokes a KafkaConsumerBackoffManager instance that will back off if necessary.
MessagingMessageListenerAdapter<K,V>	An abstract MessageListener adapter providing the necessary infrastructure to extract the payload of a Message.
MessagingMessageListenerAdapter.ReplyExpressionRoot	Root object for reply expression evaluation.
RecordMessagingMessageListenerAdapter<K,V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
RetryingMessageListenerAdapter<K,V>	A retrying message listener adapter for MessageListeners.