Package org.springframework.kafka.listener.adapter

@NonNullApi package org.springframework.kafka.listener.adapter

Provides classes for adapting listeners.

Related Packages

Package	Description
org.springframework.kafka.listener	Package for kafka listeners

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.
AsyncRepliesAware	Message handler adapter implementing this interface can detect HandlerAdapter async return types.
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.
BatchToRecordAdapter<K,V>	An adapter that adapts a batch listener to a record listener method.
BatchToRecordAdapter.Callback<K,V>	A callback for each message.
ConsumerRecordMetadata	Used to provide a listener method argument when the user supplies such a parameter.
ContinuationHandlerMethodArgumentResolver	No-op resolver for method arguments of type Continuation.
ConvertingMessageListener<V>	A AcknowledgingConsumerAwareMessageListener adapter that implements converting received ConsumerRecord using specified MessageConverter and then passes result to specified MessageListener.
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.
KafkaMessageHandlerMethodFactory	Extension of the DefaultMessageHandlerMethodFactory for Spring Kafka requirements.
KafkaNullAwarePayloadArgumentResolver	PayloadMethodArgumentResolver that can properly decode KafkaNull payloads, returning null.
KotlinAwareInvocableHandlerMethod	An InvocableHandlerMethod extension for supporting Kotlin suspend function.
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.
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.
RecordMessagingMessageListenerAdapter<K,V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
ReplyHeadersConfigurer	A strategy for configuring which headers, if any, should be set in a reply message.