Uses of Class
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
-
Uses of ListenerContainerFactoryConfigurer in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicComponentFactory.listenerContainerFactoryConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, Clock clock) Create aListenerContainerFactoryConfigurer
that will be used to configure theKafkaListenerContainerFactory
resolved by theListenerContainerFactoryResolver
.Modifier and TypeMethodDescriptionprotected Consumer<ListenerContainerFactoryConfigurer>
RetryTopicConfigurationSupport.configureListenerContainerFactoryConfigurer()
Override this method to further configure theListenerContainerFactoryConfigurer
.Modifier and TypeMethodDescriptionRetryTopicComponentFactory.retryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create theRetryTopicConfigurer
that will serve as an entry point for configuring non-blocking topic-based delayed retries for a givenKafkaListenerEndpoint
, by processing the appropriateRetryTopicConfiguration
.ModifierConstructorDescriptionRetryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryResolver containerFactoryResolver, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create an instance with the provided properties.