Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfiguration
Package
Description
Package for kafka annotations
Package for retryable topic handling.
-
Uses of RetryTopicConfiguration in org.springframework.kafka.annotation
Modifier and TypeMethodDescriptionRetryTopicConfigurationProvider.findRetryConfigurationFor
(String[] topics, Method method, Class<?> clazz, Object bean) Find retry topic configuration.RetryTopicConfigurationProvider.findRetryConfigurationFor
(String[] topics, Method method, Object bean) RetryableTopicAnnotationProcessor.processAnnotation
(String[] topics, Class<?> clazz, RetryableTopic annotation, Object bean) RetryableTopicAnnotationProcessor.processAnnotation
(String[] topics, Method method, RetryableTopic annotation, Object bean) -
Uses of RetryTopicConfiguration in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.create
(KafkaOperations<?, ?> sendToTopicKafkaTemplate) Create theRetryTopicConfiguration
with the provided template.Modifier and TypeMethodDescriptionprotected EndpointHandlerMethod
RetryTopicConfigurer.getEndpointHandlerMethod
(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) void
RetryTopicConfigurer.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.