Uses of Class
org.springframework.kafka.retrytopic.DestinationTopic

Packages that use DestinationTopic

Package	Description
org.springframework.kafka.retrytopic	Package for retryable topic handling.

Uses of DestinationTopic in org.springframework.kafka.retrytopic

Fields in org.springframework.kafka.retrytopic with type parameters of type DestinationTopic

Modifier and Type	Field	Description
protected final Map<String,List<DestinationTopic>>	DestinationTopicProcessor.Context.destinationsByTopicMap

Methods in org.springframework.kafka.retrytopic that return DestinationTopic

Modifier and Type	Method	Description
DestinationTopic	DefaultDestinationTopicResolver.getDestinationTopicByName(String mainListenerId, String topic)
DestinationTopic	DestinationTopicContainer.getDestinationTopicByName(String mainListenerId, String topicName)	Returns the DestinationTopic instance registered for that topic.
DestinationTopic	DefaultDestinationTopicResolver.getDltFor(String mainListenerId, String topicName, Exception e)
default DestinationTopic	DestinationTopicContainer.getDltFor(String mainListenerId, String topicName)	Deprecated, for removal: This API element is subject to removal in a future version. Replaced by DestinationTopicContainer.getDltFor(String, String, Exception)
default DestinationTopic	DestinationTopicContainer.getDltFor(String mainListenerId, String topicName, Exception exc)	Returns the DestinationTopic instance registered as DLT for the given topic taking into consideration the exception thrown, or null if none is found.
protected DestinationTopic	DefaultDestinationTopicResolver.DestinationTopicHolder.getNextDestination()
DestinationTopic	DefaultDestinationTopicResolver.getNextDestinationTopicFor(String mainListenerId, String topic)
DestinationTopic	DestinationTopicContainer.getNextDestinationTopicFor(String mainListenerId, String topicName)	Returns the DestinationTopic instance registered as the next destination topic in the chain for the given topic.
protected DestinationTopic	DefaultDestinationTopicResolver.DestinationTopicHolder.getSourceDestination()
DestinationTopic	DefaultDestinationTopicResolver.resolveDestinationTopic(String mainListenerId, String topic, Integer attempt, Exception e, long originalTimestamp)
DestinationTopic	DestinationTopicResolver.resolveDestinationTopic(String mainListenerId, String topic, Integer attempt, Exception e, long originalTimestamp)	Resolves the destination topic for the failed message.

Methods in org.springframework.kafka.retrytopic with parameters of type DestinationTopic

Modifier and Type	Method	Description
protected void	DeadLetterPublishingRecovererFactory.maybeLogListenerException(Exception exception, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, DestinationTopic nextDestination)	Log the exception before sending the record in error to the retry topic.
protected org.apache.kafka.common.TopicPartition	DeadLetterPublishingRecovererFactory.resolveTopicPartition(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> cr, DestinationTopic nextDestination)	Creates and returns the TopicPartition, where the original record should be forwarded.

Method parameters in org.springframework.kafka.retrytopic with type arguments of type DestinationTopic

Modifier and Type	Method	Description
void	DefaultDestinationTopicResolver.addDestinationTopics(String mainListenerId, List<DestinationTopic> destinationsToAdd)
void	DestinationTopicContainer.addDestinationTopics(String mainListenerId, List<DestinationTopic> destinationTopics)	Adds the provided destination topics to the container.

Constructors in org.springframework.kafka.retrytopic with parameters of type DestinationTopic

Modifier	Constructor	Description
	DestinationTopic(String destinationName, DestinationTopic sourceDestinationtopic, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)