Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfigurer
Packages that use RetryTopicConfigurer
-
Uses of RetryTopicConfigurer in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return RetryTopicConfigurerModifier and TypeMethodDescriptionRetryTopicComponentFactory.retryTopicConfigurer(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create theRetryTopicConfigurerthat 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 globalRetryTopicConfigurerfor configuring retry topics forKafkaListenerEndpointinstances with a correspondingRetryTopicConfiguration.Methods in org.springframework.kafka.retrytopic that return types with arguments of type RetryTopicConfigurerModifier and TypeMethodDescriptionprotected Consumer<RetryTopicConfigurer>RetryTopicConfigurationSupport.configureRetryTopicConfigurer()Override this method if you need to configure theRetryTopicConfigurer.