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.AMessageListeneradapter 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.AAcknowledgingConsumerAwareMessageListeneradapter that implements converting receivedConsumerRecordusing specifiedMessageConverterand then passes result to specifiedMessageListener.The defaultBatchToRecordAdapterimplementation; if the supplied recoverer throws an exception, the batch will be aborted; otherwise the next record will be processed.Delegates to anInvocableHandlerMethodbased on the message payload type.ABatchMessageListeneradapter that implements filter logic via aRecordFilterStrategy.AMessageListeneradapter that implements filter logic via aRecordFilterStrategy.A wrapper for either anInvocableHandlerMethodorDelegatingInvocableHandler.The result of a method invocation.AAcknowledgingConsumerAwareMessageListenerimplementation that looks for a backoff dueTimestamp header and invokes aKafkaConsumerBackoffManagerinstance that will back off if necessary.An abstractMessageListeneradapter 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.AMessageListeneradapter 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.