Uses of Interface
org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory
-
Uses of RetryTopicNamesProviderFactory in org.springframework.kafka.retrytopic
Modifier and TypeClassDescriptionclass
Retry and dead letter naming handling that add a suffix to each name.Modifier and TypeMethodDescriptionRetryTopicComponentFactory.retryTopicNamesProviderFactory()
Create theRetryTopicNamesProviderFactory
instance that will be used to provide the property names for the retry topics'KafkaListenerEndpoint
.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
.ModifierConstructorDescriptionEndpointCustomizerFactory
(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) RetryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryResolver containerFactoryResolver, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create an instance with the provided properties.