Uses of Class
org.springframework.kafka.listener.ConcurrentMessageListenerContainer
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.config
Modifier and TypeMethodDescriptionprotected ConcurrentMessageListenerContainer<K,
V> ConcurrentKafkaListenerContainerFactory.createContainerInstance
(KafkaListenerEndpoint endpoint) Modifier and TypeMethodDescriptionprotected void
ConcurrentKafkaListenerContainerFactory.initializeContainer
(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) -
Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionprotected void
ListenerContainerFactoryConfigurer.setupBackoffAwareMessageListenerAdapter
(ConcurrentMessageListenerContainer<?, ?> container, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration, boolean isSetContainerProperties) Modifier and TypeMethodDescriptionRetryTopicConfigurationSupport.CustomizersConfigurer.customizeListenerContainer
(Consumer<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) Customize theConcurrentMessageListenerContainer
instances created for the retry and DLT consumers.void
ListenerContainerFactoryConfigurer.setContainerCustomizer
(Consumer<ConcurrentMessageListenerContainer<?, ?>> containerCustomizer)