Uses of Class
org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Packages that use ConcurrentMessageListenerContainer

Package	Description
org.springframework.kafka.config	Package for kafka configuration
org.springframework.kafka.retrytopic	Package for retryable topic handling.

Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.config

Subclasses with type arguments of type ConcurrentMessageListenerContainer in org.springframework.kafka.config

Modifier and Type	Class	Description
class	ConcurrentKafkaListenerContainerFactory<K,V>	A KafkaListenerContainerFactory implementation to build a ConcurrentMessageListenerContainer.

Methods in org.springframework.kafka.config that return ConcurrentMessageListenerContainer

Modifier and Type	Method	Description
protected ConcurrentMessageListenerContainer<K,V>	ConcurrentKafkaListenerContainerFactory.createContainerInstance(KafkaListenerEndpoint endpoint)

Methods in org.springframework.kafka.config with parameters of type ConcurrentMessageListenerContainer

Modifier and Type	Method	Description
protected void	ConcurrentKafkaListenerContainerFactory.initializeContainer(ConcurrentMessageListenerContainer<K,V> instance, KafkaListenerEndpoint endpoint)

Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.retrytopic

Methods in org.springframework.kafka.retrytopic with parameters of type ConcurrentMessageListenerContainer

Modifier and Type	Method	Description
protected void	ListenerContainerFactoryConfigurer.setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?,?> container)

Method parameters in org.springframework.kafka.retrytopic with type arguments of type ConcurrentMessageListenerContainer

Modifier and Type	Method	Description
RetryTopicConfigurationSupport.CustomizersConfigurer	RetryTopicConfigurationSupport.CustomizersConfigurer.customizeListenerContainer(Consumer<ConcurrentMessageListenerContainer<?,?>> listenerContainerCustomizer)	Customize the ConcurrentMessageListenerContainer instances created for the retry and DLT consumers.
void	ListenerContainerFactoryConfigurer.setContainerCustomizer(@Nullable Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)