Uses of Interface
org.springframework.kafka.listener.GenericMessageListener
Packages that use GenericMessageListener
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
-
Uses of GenericMessageListener in org.springframework.kafka.listener
Subinterfaces of GenericMessageListener 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 a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interface
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interface
Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.interface
BatchMessageListener<K,
V> Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.interface
Listener for handling individual incoming Kafka messages.interface
MessageListener<K,
V> Listener for handling individual incoming Kafka messages. -
Uses of GenericMessageListener in org.springframework.kafka.listener.adapter
Classes in org.springframework.kafka.listener.adapter that implement GenericMessageListenerModifier and TypeClassDescriptionclass
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive batches of messages.class
AAcknowledgingConsumerAwareMessageListener
adapter that implements converting receivedConsumerRecord
using specifiedMessageConverter
and then passes result to specifiedMessageListener
.class
ABatchMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.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. -
Uses of GenericMessageListener in org.springframework.kafka.requestreply
Classes in org.springframework.kafka.requestreply that implement GenericMessageListenerModifier and TypeClassDescriptionclass
A replying template that aggregates multiple replies with the same correlation id.class
ReplyingKafkaTemplate<K,
V, R> A KafkaTemplate that implements request/reply semantics.