Uses of Interface
org.springframework.kafka.listener.MessageListener
Packages that use MessageListener
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
-
Uses of MessageListener in org.springframework.kafka.listener
Subinterfaces of MessageListener in org.springframework.kafka.listenerModifier and TypeInterfaceDescriptioninterface
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interface
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interface
Listener for handling individual incoming Kafka messages. -
Uses of MessageListener in org.springframework.kafka.listener.adapter
Classes in org.springframework.kafka.listener.adapter that implement MessageListenerModifier and TypeClassDescriptionclass
AAcknowledgingConsumerAwareMessageListener
adapter that implements converting receivedConsumerRecord
using specifiedMessageConverter
and then passes result to specifiedMessageListener
.class
AMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.class
AAcknowledgingConsumerAwareMessageListener
implementation that looks for a backoff dueTimestamp header and invokes aKafkaConsumerBackoffManager
instance that will back off if necessary.class
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages.Methods in org.springframework.kafka.listener.adapter that return MessageListenerConstructors in org.springframework.kafka.listener.adapter with parameters of type MessageListenerModifierConstructorDescriptionConvertingMessageListener
(MessageListener<?, V> delegateMessageListener, Class<V> desiredValueType) Construct an instance with the providedMessageListener
andClass
as a desired type ofConsumerRecord
's value after conversion.FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) Create an instance with the supplied strategy and delegate listener.FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) Create an instance with the supplied strategy and delegate listener.KafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> delegate, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, String listenerId, String backoffTimestampHeader, Clock clock) The configuration for this listener adapter.KafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> adapter, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, String listenerId, Clock clock)