Uses of Package
org.springframework.kafka.retrytopic
Packages that use org.springframework.kafka.retrytopic
Package
Description
Package for kafka annotations
Package for retryable topic handling.
-
Classes in org.springframework.kafka.retrytopic used by org.springframework.kafka.annotationClassDescriptionContains the provided configuration for the retryable topics.
-
Classes in org.springframework.kafka.retrytopic used by org.springframework.kafka.retrytopicClassDescriptionCreates and configures the
DeadLetterPublishingRecovererthat will be used to forward the messages using theDestinationTopicResolver.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.Defines the topic strategy to handle fixed delays.Decorates the providedConcurrentKafkaListenerContainerFactoryto add aDefaultErrorHandlerand theDeadLetterPublishingRecoverercreated by theDeadLetterPublishingRecovererFactory.Resolves aConcurrentKafkaListenerContainerFactoryto be used by theRetryTopicConfiguration.Contains the provided configuration for the retryable topics.Builder class to createRetryTopicConfigurationinstances.Handles the naming related to the retry and dead letter topics.Constants for the RetryTopic functionality.