Package org.springframework.kafka.retrytopic

@NonNullApi @NonNullFields 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.
DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator	Implement this interface to create each DeadLetterPublishingRecoverer.
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<T extends MethodKafkaListenerEndpoint<?,?>>	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.
ExceptionBasedDltDestination	Annotation allowing to specify additional DLT which will be chosen when message processing caused the configured exception to be thrown.
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.
RetryTopicBeanNames	The bean names for the non-blocking topic-based delayed retries feature.
RetryTopicComponentFactory	Provide the component instances that will be used with RetryTopicConfigurationSupport.
RetryTopicConfiguration	Contains the provided configuration for the retryable topics.
RetryTopicConfigurationBuilder	Builder class to create RetryTopicConfiguration instances.
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 accomplish 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.
RetryTopicNamesProviderFactory	Handles the naming related to the retry and dead letter topics.
RetryTopicNamesProviderFactory.RetryTopicNamesProvider
RetryTopicSchedulerWrapper	A wrapper class for a TaskScheduler to use for scheduling container resumption when a partition has been paused for a retry topic.
SameIntervalTopicReuseStrategy	Strategy for topic reuse when multiple, sequential retries have the same backoff interval.
SuffixingRetryTopicNamesProviderFactory	Retry and dead letter naming handling that add a suffix to each name.
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
TopicSuffixingStrategy	Constants for the RetryTopic functionality.