Package org.springframework.kafka.retrytopic

package org.springframework.kafka.retrytopic

Package for retryable topic handling.

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka

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.
DefaultDestinationTopicProcessor	Default implementation of the DestinationTopicProcessor interface.
DefaultDestinationTopicResolver	Default implementation of the DestinationTopicResolver interface.
DefaultDestinationTopicResolver.DestinationTopicHolder
DestinationTopic	Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.
DestinationTopic.Properties
DestinationTopicContainer	Provides methods to store and retrieve DestinationTopic instances.
DestinationTopicProcessor	The DestinationTopicProcessor creates and registers the DestinationTopic instances in the provided DestinationTopicProcessor.Context, also providing callback interfaces to be called upon the context properties.
DestinationTopicProcessor.Context
DestinationTopicPropertiesFactory	Creates a list of DestinationTopic.Properties based on the provided configurations.
DestinationTopicPropertiesFactory.DestinationTopicSuffixes
DestinationTopicResolver	Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.
DltStrategy	Strategies for handling DLT processing.
EndpointCustomizer	Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.
EndpointCustomizer.TopicNamesHolder
EndpointCustomizerFactory	Creates the EndpointCustomizer that will be used by the RetryTopicConfigurer to customize the main, retry and DLT endpoints.
FixedDelayStrategy	Defines the topic strategy to handle fixed delays.
ListenerContainerFactoryConfigurer	Decorates the provided ConcurrentKafkaListenerContainerFactory to add a DefaultErrorHandler and the DeadLetterPublishingRecoverer created by the DeadLetterPublishingRecovererFactory.
ListenerContainerFactoryResolver	Resolves a ConcurrentKafkaListenerContainerFactory to be used by the 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.
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.EndpointProcessor
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.
RetryTopicNamesProviderFactory	Handles the naming related to the retry and dead letter topics.
RetryTopicNamesProviderFactory.RetryTopicNamesProvider
SuffixingRetryTopicNamesProviderFactory	Retry and dead letter naming handling that add a suffix to each name.
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
TopicSuffixingStrategy	Constants for the RetryTopic functionality.