Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfiguration
Packages that use RetryTopicConfiguration
Package
Description
Package for kafka annotations
Package for retryable topic handling.
-
Uses of RetryTopicConfiguration in org.springframework.kafka.annotation
Methods in org.springframework.kafka.annotation that return RetryTopicConfigurationModifier and TypeMethodDescriptionRetryTopicConfigurationProvider.findRetryConfigurationFor(String[] topics, Method method, Object bean) RetryableTopicAnnotationProcessor.processAnnotation(String[] topics, Method method, RetryableTopic annotation, Object bean) -
Uses of RetryTopicConfiguration in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return RetryTopicConfigurationModifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.create(KafkaOperations<?, ?> sendToTopicKafkaTemplate) Create theRetryTopicConfigurationwith the provided template.Methods in org.springframework.kafka.retrytopic with parameters of type RetryTopicConfigurationModifier and TypeMethodDescriptionprotected EndpointHandlerMethodRetryTopicConfigurer.getEndpointHandlerMethod(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) voidRetryTopicConfigurer.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.