Package org.springframework.kafka.listener.adapter
@NonNullApi
package org.springframework.kafka.listener.adapter
Provides classes for adapting listeners.
-
ClassDescriptionTop level class for all listener adapters.An abstract message listener adapter that implements record filter logic via a
RecordFilterStrategy
.Base class for retrying message listener adapters.Utilities for listener adapters.AMessageListener
adapter that invokes a configurableHandlerAdapter
; 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.A callback for each message.Used to provide a listener method argument when the user supplies such a parameter.AAcknowledgingConsumerAwareMessageListener
adapter that implements converting receivedConsumerRecord
using specifiedMessageConverter
and then passes result to specifiedMessageListener
.The defaultBatchToRecordAdapter
implementation; if the supplied recoverer throws an exception, the batch will be aborted; otherwise the next record will be processed.Delegates to anInvocableHandlerMethod
based on the message payload type.ABatchMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.AMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.A wrapper for either anInvocableHandlerMethod
orDelegatingInvocableHandler
.The result of a method invocation.AAcknowledgingConsumerAwareMessageListener
implementation that looks for a backoff dueTimestamp header and invokes aKafkaConsumerBackoffManager
instance that will back off if necessary.An abstractMessageListener
adapter providing the necessary infrastructure to extract the payload of aMessage
.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.AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages.A strategy for configuring which headers, if any, should be set in a reply message.