Package org.springframework.kafka.retrytopic

Interface Summary

Interface	Description
RetryTopicConfigurer.EndpointProcessor

Class Summary

Class	Description
BackOffValuesGenerator	Generates the backoff values from the provided maxAttempts value and BackOffPolicy.
DeadLetterPublishingRecovererFactory	Creates and configures the DeadLetterPublishingRecoverer that will be used to forward the messages using the DestinationTopicResolver.
DeadLetterPublishingRecovererFactory.Configuration
ListenerContainerFactoryConfigurer	Configures the provided ConcurrentKafkaListenerContainerFactory with a SeekToCurrentErrorHandler, the DeadLetterPublishingRecoverer created by the DeadLetterPublishingRecovererFactory.
ListenerContainerFactoryResolver	Resolves a ConcurrentKafkaListenerContainerFactory to be used by the RetryTopicConfiguration.
RetryableTopicAnnotationProcessor	Processes the provided RetryableTopic annotation returning an RetryTopicConfiguration.
RetryTopicBootstrapper	Bootstraps the RetryTopicConfigurer context, registering the dependency beans and configuring the ApplicationListeners.
RetryTopicConfiguration	Contains the provided configuration for the retryable topics.
RetryTopicConfigurationBuilder	Builder class to create RetryTopicConfiguration instances.
RetryTopicConfigurationProvider	Attempts to provide an instance of RetryTopicConfigurer by either creating one from a RetryableTopic annotation, or from the bean container if no annotation is available.
RetryTopicConfigurer	Configures main, retry and DLT topics based on a main endpoint and provided configurations to acomplish a distributed retry / DLT pattern in a non-blocking fashion, at the expense of ordering guarantees.
RetryTopicConfigurer.EndpointProcessingCustomizerHolder	Creates the endpoint and factory customizers that will be called at the end of the KafkaListenerAnnotationBeanPostProcessor's processListener(MethodKafkaListenerEndpoint, KafkaListener, Object, Object, String)} method.
RetryTopicConstants	Constants for the RetryTopic functionality.
RetryTopicHeaders	Contains the headers that will be used in the forwarded messages.
RetryTopicInternalBeanNames	Contains the internal bean names that will be used by the retryable topic configuration.

Enum Summary

Enum	Description
DltStrategy	Strategies for handling DLT processing.
FixedDelayStrategy	Defines the topic strategy to handle fixed delays.
TopicSuffixingStrategy	Constants for the RetryTopic functionality.