Package org.springframework.kafka.retrytopic.destinationtopic
-
Interface Summary Interface Description DestinationTopicProcessor TheDestinationTopicProcessor
creates and registers theDestinationTopic
instances in the providedDestinationTopicProcessor.Context
, also providing callback interfaces to be called upon the context properties.DestinationTopicResolver Contains methods for resolving the destination to which a message that failed to be processed should be forwarded to, based on the current topic, the attempt and the thrown exception. -
Class Summary Class Description DefaultDestinationTopicProcessor Default implementation of theDestinationTopicProcessor
interface.DestinationTopic Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.DestinationTopic.Properties DestinationTopicContainer Contains the destination topics and correlates them with their source via the Map<String,DestinationTopicResolver.DestinationsHolder
> map.DestinationTopicProcessor.Context DestinationTopicPropertiesFactory Creates a list ofDestinationTopic.Properties
based on the provided configurations.DestinationTopicPropertiesFactory.DestinationTopicSuffixes DestinationTopicResolver.DestinationsHolder