Uses of Interface
org.springframework.kafka.listener.BatchMessageListener
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
-
Uses of BatchMessageListener in org.springframework.kafka.listener
Modifier and TypeInterfaceDescriptioninterface
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. -
Uses of BatchMessageListener in org.springframework.kafka.listener.adapter
Modifier and TypeClassDescriptionclass
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive batches of messages.class
ABatchMessageListener
adapter that implements filter logic via aRecordFilterStrategy
.ModifierConstructorDescriptionFilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) Create an instance with the supplied strategy and delegate listener.FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) Create an instance with the supplied strategy and delegate listener. -
Uses of BatchMessageListener in org.springframework.kafka.requestreply
Modifier 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.