Uses of Interface
org.springframework.kafka.listener.GenericMessageListenerContainer
Packages that use GenericMessageListenerContainer
Package
Description
Package for kafka listeners
Provides classes for request/reply semantics.
-
Uses of GenericMessageListenerContainer in org.springframework.kafka.listener
Classes in org.springframework.kafka.listener that implement GenericMessageListenerContainerModifier and TypeClassDescriptionclassThe base implementation for theMessageListenerContainer.classCreates 1 or moreKafkaMessageListenerContainers based onconcurrency.classSingle-threaded Message listener container using the JavaConsumersupporting auto-partition assignment or user-configured assignment. -
Uses of GenericMessageListenerContainer in org.springframework.kafka.requestreply
Constructors in org.springframework.kafka.requestreply with parameters of type GenericMessageListenerContainerModifierConstructorDescriptionAggregatingReplyingKafkaTemplate(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)