Package org.springframework.kafka.retrytopic
package org.springframework.kafka.retrytopic
Package for retryable topic handling.
-
ClassDescriptionGenerates the backoff values from the provided maxAttempts value and
BackOffPolicy.Creates and configures theDeadLetterPublishingRecovererthat will be used to forward the messages using theDestinationTopicResolver.Default implementation of theDestinationTopicProcessorinterface.Default implementation of the DestinationTopicResolver interface.Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.Provides methods to store and retrieveDestinationTopicinstances.TheDestinationTopicProcessorcreates and registers theDestinationTopicinstances in the providedDestinationTopicProcessor.Context, also providing callback interfaces to be called upon the context properties.Creates a list ofDestinationTopic.Propertiesbased on the provided configurations.Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.Strategies for handling DLT processing.Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.Creates theEndpointCustomizerthat will be used by theRetryTopicConfigurerto customize the main, retry and DLT endpoints.Defines the topic strategy to handle fixed delays.Decorates the providedConcurrentKafkaListenerContainerFactoryto add aDefaultErrorHandlerand theDeadLetterPublishingRecoverercreated by theDeadLetterPublishingRecovererFactory.Resolves aConcurrentKafkaListenerContainerFactoryto be used by theRetryTopicConfiguration.Bootstraps theRetryTopicConfigurercontext, registering the dependency beans and configuring theApplicationListeners.Contains the provided configuration for the retryable topics.Builder class to createRetryTopicConfigurationinstances.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.Constants for the RetryTopic functionality.Contains the headers that will be used in the forwarded messages.Contains the internal bean names that will be used by the retryable topic configuration.Handles the naming related to the retry and dead letter topics.Retry and dead letter naming handling that add a suffix to each name.Constants for the RetryTopic functionality.