Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfigurer
-
Uses of RetryTopicConfigurer in org.springframework.kafka.retrytopic
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
.RetryTopicConfigurationSupport.retryTopicConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) Return a globalRetryTopicConfigurer
for configuring retry topics forKafkaListenerEndpoint
instances with a correspondingRetryTopicConfiguration
.Modifier and TypeMethodDescriptionprotected Consumer<RetryTopicConfigurer>
RetryTopicConfigurationSupport.configureRetryTopicConfigurer()
Override this method if you need to configure theRetryTopicConfigurer
.