Uses of Class
org.springframework.kafka.retrytopic.DestinationTopic
-
Uses of DestinationTopic in org.springframework.kafka.retrytopic
Modifier and TypeFieldDescriptionprotected final Map<String,
List<DestinationTopic>> DestinationTopicProcessor.Context.destinationsByTopicMap
Modifier and TypeMethodDescriptionDefaultDestinationTopicResolver.getDestinationTopicByName
(String mainListenerId, String topic) DestinationTopicContainer.getDestinationTopicByName
(String mainListenerId, String topicName) Returns theDestinationTopic
instance registered for that topic.Returns theDestinationTopic
instance registered as DLT for the given topic, or null if none is found.protected DestinationTopic
DefaultDestinationTopicResolver.DestinationTopicHolder.getNextDestination()
DefaultDestinationTopicResolver.getNextDestinationTopicFor
(String mainListenerId, String topic) DestinationTopicContainer.getNextDestinationTopicFor
(String mainListenerId, String topicName) Returns theDestinationTopic
instance registered as the next destination topic in the chain for the given topic.protected DestinationTopic
DefaultDestinationTopicResolver.DestinationTopicHolder.getSourceDestination()
DefaultDestinationTopicResolver.resolveDestinationTopic
(String mainListenerId, String topic, Integer attempt, Exception e, long originalTimestamp) DestinationTopicResolver.resolveDestinationTopic
(String mainListenerId, String topic, Integer attempt, Exception e, long originalTimestamp) Resolves the destination topic for the failed message.Modifier and TypeMethodDescriptionprotected org.apache.kafka.common.TopicPartition
DeadLetterPublishingRecovererFactory.resolveTopicPartition
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> cr, DestinationTopic nextDestination) Creates and returns theTopicPartition
, where the original record should be forwarded.Modifier and TypeMethodDescriptionvoid
DefaultDestinationTopicResolver.addDestinationTopics
(String mainListenerId, List<DestinationTopic> destinationsToAdd) void
DestinationTopicContainer.addDestinationTopics
(String mainListenerId, List<DestinationTopic> destinationTopics) Adds the provided destination topics to the container.ModifierConstructorDescriptionDestinationTopic
(String destinationName, DestinationTopic sourceDestinationtopic, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)