Package org.springframework.kafka.retrytopic.destinationtopic
-
Interface Summary Interface Description DestinationTopicProcessor TheDestinationTopicProcessorcreates and registers theDestinationTopicinstances 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 theDestinationTopicProcessorinterface.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.Propertiesbased on the provided configurations.DestinationTopicPropertiesFactory.DestinationTopicSuffixes DestinationTopicResolver.DestinationsHolder