Uses of Interface
org.springframework.kafka.config.KafkaListenerContainerFactory
Packages that use KafkaListenerContainerFactory
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of KafkaListenerContainerFactory in org.springframework.kafka.config
Classes in org.springframework.kafka.config that implement KafkaListenerContainerFactoryModifier and TypeClassDescriptionclassAbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>, K, V> BaseKafkaListenerContainerFactoryfor Spring's base container implementation.classAKafkaListenerContainerFactoryimplementation to build aConcurrentMessageListenerContainer.Methods in org.springframework.kafka.config with parameters of type KafkaListenerContainerFactoryModifier and TypeMethodDescriptionprotected MessageListenerContainerKafkaListenerEndpointRegistry.createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create and start a newMessageListenerContainerusing the specified factory.voidKafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Register a newKafkaListenerEndpointalongside theKafkaListenerContainerFactoryto use to create the underlying container.voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create a message listener container for the givenKafkaListenerEndpoint.voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately) Create a message listener container for the givenKafkaListenerEndpoint.voidKafkaListenerEndpointRegistrar.setContainerFactory(KafkaListenerContainerFactory<?> containerFactory) Set theKafkaListenerContainerFactoryto use in case aKafkaListenerEndpointis registered with anullcontainer factory. -
Uses of KafkaListenerContainerFactory in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return KafkaListenerContainerFactoryModifier 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.Methods in org.springframework.kafka.retrytopic with parameters of type KafkaListenerContainerFactoryModifier and TypeMethodDescriptionvoidRetryTopicConfigurer.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.