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 topic)
DestinationTopic	DestinationTopicContainer.getDestinationTopicByName(String topicName)	Returns the DestinationTopic instance registered for that topic.
protected DestinationTopic	DefaultDestinationTopicResolver.DestinationTopicHolder.getNextDestination()
protected DestinationTopic	DefaultDestinationTopicResolver.DestinationTopicHolder.getSourceDestination()
DestinationTopic	DefaultDestinationTopicResolver.resolveDestinationTopic(String topic, Integer attempt, Exception e, long originalTimestamp)
DestinationTopic	DestinationTopicResolver.resolveDestinationTopic(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 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(List<DestinationTopic> destinationsToAdd)
void	DestinationTopicContainer.addDestinationTopics(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)