Package org.springframework.kafka.retrytopic
Package for retryable topic handling.
-
Interface Summary Interface Description DestinationTopicContainer Provides methods to store and retrieveDestinationTopicinstances.DestinationTopicProcessor TheDestinationTopicProcessorcreates and registers theDestinationTopicinstances in the providedDestinationTopicProcessor.Context, also providing callback interfaces to be called upon the context properties.DestinationTopicResolver Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.EndpointCustomizer Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.RetryTopicConfigurer.EndpointProcessor RetryTopicNamesProviderFactory Handles the naming related to the retry and dead letter topics.RetryTopicNamesProviderFactory.RetryTopicNamesProvider -
Class Summary Class Description BackOffValuesGenerator Generates the backoff values from the provided maxAttempts value andBackOffPolicy.DeadLetterPublishingRecovererFactory Creates and configures theDeadLetterPublishingRecovererthat will be used to forward the messages using theDestinationTopicResolver.DefaultDestinationTopicProcessor Default implementation of theDestinationTopicProcessorinterface.DefaultDestinationTopicResolver Default implementation of theDestinationTopicResolverinterface.DefaultDestinationTopicResolver.DestinationTopicHolder DestinationTopic Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.DestinationTopic.Properties DestinationTopicProcessor.Context DestinationTopicPropertiesFactory Creates a list ofDestinationTopic.Propertiesbased on the provided configurations.DestinationTopicPropertiesFactory.DestinationTopicSuffixes EndpointCustomizer.TopicNamesHolder EndpointCustomizerFactory Creates theEndpointCustomizerthat will be used by theRetryTopicConfigurerto customize the main, retry and DLT endpoints.ListenerContainerFactoryConfigurer Decorates the providedConcurrentKafkaListenerContainerFactoryto add aDefaultErrorHandlerand theDeadLetterPublishingRecoverercreated by theDeadLetterPublishingRecovererFactory.ListenerContainerFactoryResolver Resolves aConcurrentKafkaListenerContainerFactoryto be used by theRetryTopicConfiguration.RetryTopicBeanNames The bean names for the non-blocking topic-based delayed retries feature.RetryTopicComponentFactory Provide the component instances that will be used withRetryTopicConfigurationSupport.RetryTopicConfiguration Contains the provided configuration for the retryable topics.RetryTopicConfigurationBuilder Builder class to createRetryTopicConfigurationinstances.RetryTopicConfigurationSupport This is the main class providing the configuration behind the non-blocking, topic-based delayed retries feature.RetryTopicConfigurationSupport.BlockingRetriesConfigurer Configure blocking retries to be used along non-blocking.RetryTopicConfigurationSupport.CustomizersConfigurer Configure customizers for components instantiated by the retry topics feature.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.RetryTopicConstants Constants for the RetryTopic functionality.RetryTopicHeaders Contains the headers that will be used in the forwarded messages.RetryTopicSchedulerWrapper A wrapper class for aTaskSchedulerto use for scheduling container resumption when a partition has been paused for a retry topic.SuffixingRetryTopicNamesProviderFactory Retry and dead letter naming handling that add a suffix to each name.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider -
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.