Uses of Interface
org.springframework.kafka.retrytopic.DestinationTopicResolver

Packages that use DestinationTopicResolver

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

Uses of DestinationTopicResolver in org.springframework.kafka.retrytopic

Classes in org.springframework.kafka.retrytopic that implement DestinationTopicResolver

Modifier and Type	Class	Description
class	DefaultDestinationTopicResolver	Default implementation of the DestinationTopicResolver interface.

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

Modifier and Type	Method	Description
DestinationTopicResolver	RetryTopicComponentFactory.destinationTopicResolver()	Create the instance of DestinationTopicResolver that will be used to store the DestinationTopic instance and resolve which a given record should be forwarded to.
DestinationTopicResolver	RetryTopicConfigurationSupport.destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider)	Return a global DestinationTopicResolver for resolving the DestinationTopic to which a given ConsumerRecord should be sent for retry.

Methods in org.springframework.kafka.retrytopic that return types with arguments of type DestinationTopicResolver

Modifier and Type	Method	Description
protected Consumer<DestinationTopicResolver>	RetryTopicConfigurationSupport.configureDestinationTopicResolver()	Override this method to configure the DestinationTopicResolver.

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

Modifier and Type	Method	Description
DeadLetterPublishingRecovererFactory	RetryTopicComponentFactory.deadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver)	Create the DeadLetterPublishingRecovererFactory that will be used to create the DeadLetterPublishingRecoverer to forward the records to a given DestinationTopic.
DestinationTopicProcessor	RetryTopicComponentFactory.destinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)	Create the DestinationTopicProcessor that will be used to process the DestinationTopic instances and store them in the provided DestinationTopicResolver.
RetryTopicConfigurer	RetryTopicConfigurationSupport.retryTopicConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory)	Return a global RetryTopicConfigurer for configuring retry topics for KafkaListenerEndpoint instances with a corresponding RetryTopicConfiguration.

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

Modifier	Constructor	Description
	DeadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver)
	DefaultDestinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)