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.jdocs.dynamic
Classes in org.springframework.kafka.jdocs.dynamic that implement MessageListener -
Uses of MessageListener in org.springframework.kafka.listener
Subinterfaces of MessageListener in org.springframework.kafka.listenerModifier and TypeInterfaceDescriptioninterfaceListener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interfaceListener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interfaceListener 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 TypeClassDescriptionclassAAcknowledgingConsumerAwareMessageListeneradapter that implements converting receivedConsumerRecordusing specifiedMessageConverterand then passes result to specifiedMessageListener.classAMessageListeneradapter that implements filter logic via aRecordFilterStrategy.classAAcknowledgingConsumerAwareMessageListenerimplementation that looks for a backoff dueTimestamp header and invokes aKafkaConsumerBackoffManagerinstance that will back off if necessary.classAMessageListeneradapter 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 providedMessageListenerandClassas 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)