Uses of Interface
org.springframework.kafka.listener.BatchMessageListener
Packages that use 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
Subinterfaces of BatchMessageListener in org.springframework.kafka.listenerModifier and TypeInterfaceDescriptioninterfaceListener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interfaceListener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.interfaceListener 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
Classes in org.springframework.kafka.listener.adapter that implement BatchMessageListenerModifier and TypeClassDescriptionclassAMessageListeneradapter that invokes a configurableHandlerAdapter; used when the factory is configured for the listener to receive batches of messages.classABatchMessageListeneradapter that implements filter logic via aRecordFilterStrategy.Constructors in org.springframework.kafka.listener.adapter with parameters of type BatchMessageListenerModifierConstructorDescriptionFilteringBatchMessageListenerAdapter(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
Classes in org.springframework.kafka.requestreply that implement BatchMessageListenerModifier and TypeClassDescriptionclassA replying template that aggregates multiple replies with the same correlation id.classReplyingKafkaTemplate<K,V, R> A KafkaTemplate that implements request/reply semantics.