Uses of Package
org.springframework.kafka.retrytopic
Package
Description
Package for kafka annotations
Package for retryable topic handling.
-
ClassDescriptionContains the provided configuration for the retryable topics.
-
ClassDescriptionCreates and configures the
DeadLetterPublishingRecoverer
that will be used to forward the messages using theDestinationTopicResolver
.Implement this interface to create eachDeadLetterPublishingRecoverer
.Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.Provides methods to store and retrieveDestinationTopic
instances.TheDestinationTopicProcessor
creates and registers theDestinationTopic
instances in the providedDestinationTopicProcessor.Context
, also providing callback interfaces to be called upon the context properties.Creates a list ofDestinationTopic.Properties
based 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.Decorates the providedConcurrentKafkaListenerContainerFactory
to add aDefaultErrorHandler
and theDeadLetterPublishingRecoverer
created by theDeadLetterPublishingRecovererFactory
.Resolves aConcurrentKafkaListenerContainerFactory
to be used by theRetryTopicConfiguration
.Provide the component instances that will be used withRetryTopicConfigurationSupport
.Contains the provided configuration for the retryable topics.Builder class to createRetryTopicConfiguration
instances.Configure blocking retries to be used along non-blocking.Configure customizers for components instantiated by the retry topics feature.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.Handles the naming related to the retry and dead letter topics.A wrapper class for aTaskScheduler
to use for scheduling container resumption when a partition has been paused for a retry topic.Strategy for topic reuse when multiple, sequential retries have the same backoff interval.Constants for the RetryTopic functionality.