Uses of Interface
org.springframework.kafka.listener.GenericMessageListenerContainer
Package
Description
Package for kafka listeners
Provides classes for request/reply semantics.
-
Uses of GenericMessageListenerContainer in org.springframework.kafka.listener
Modifier and TypeClassDescriptionclass
The base implementation for theMessageListenerContainer
.class
Creates 1 or moreKafkaMessageListenerContainer
s based onconcurrency
.class
Single-threaded Message listener container using the JavaConsumer
supporting auto-partition assignment or user-configured assignment. -
Uses of GenericMessageListenerContainer in org.springframework.kafka.requestreply
ModifierConstructorDescriptionAggregatingReplyingKafkaTemplate
(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> replyContainer, BiPredicate<List<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>, Boolean> releaseStrategy) Construct an instance using the provided parameter arguments.ReplyingKafkaTemplate
(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer) ReplyingKafkaTemplate
(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer, boolean autoFlush)