Uses of Interface
org.springframework.kafka.config.KafkaListenerContainerFactory
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of KafkaListenerContainerFactory in org.springframework.kafka.config
Modifier and TypeClassDescriptionclass
AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,
V>, K, V> BaseKafkaListenerContainerFactory
for Spring's base container implementation.class
AKafkaListenerContainerFactory
implementation to build aConcurrentMessageListenerContainer
.Modifier and TypeMethodDescriptionprotected MessageListenerContainer
KafkaListenerEndpointRegistry.createListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create and start a newMessageListenerContainer
using the specified factory.void
KafkaListenerEndpointRegistrar.registerEndpoint
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Register a newKafkaListenerEndpoint
alongside theKafkaListenerContainerFactory
to use to create the underlying container.void
KafkaListenerEndpointRegistry.registerListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create a message listener container for the givenKafkaListenerEndpoint
.void
KafkaListenerEndpointRegistry.registerListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately) Create a message listener container for the givenKafkaListenerEndpoint
.void
KafkaListenerEndpointRegistrar.setContainerFactory
(KafkaListenerContainerFactory<?> containerFactory) Set theKafkaListenerContainerFactory
to use in case aKafkaListenerEndpoint
is registered with anull
container factory. -
Uses of KafkaListenerContainerFactory in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionListenerContainerFactoryConfigurer.decorateFactory
(ConcurrentKafkaListenerContainerFactory<?, ?> factory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration) Decorates the providedConcurrentKafkaListenerContainerFactory
.ListenerContainerFactoryConfigurer.decorateFactoryWithoutSettingContainerProperties
(ConcurrentKafkaListenerContainerFactory<?, ?> factory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration) Decorates the providedConcurrentKafkaListenerContainerFactory
.Modifier and TypeMethodDescriptionvoid
RetryTopicConfigurer.processMainAndRetryListeners
(RetryTopicConfigurer.EndpointProcessor endpointProcessor, MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, KafkaListenerEndpointRegistrar registrar, KafkaListenerContainerFactory<?> factory, String defaultContainerFactoryBeanName) Entrypoint for creating and configuring the retry and dlt endpoints, as well as the container factory that will create the corresponding listenerContainer.