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

Packages that use RetryTopicComponentFactory

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

Uses of RetryTopicComponentFactory in org.springframework.kafka.retrytopic

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

Modifier and Type	Method	Description
protected RetryTopicComponentFactory	RetryTopicConfigurationSupport.createComponentFactory()	Override this method to provide a subclass of RetryTopicComponentFactory with different component implementations or subclasses.

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

Modifier and Type	Method	Description
DestinationTopicResolver	RetryTopicConfigurationSupport.destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider)	Return a global DestinationTopicResolver for resolving the DestinationTopic to which a given ConsumerRecord should be sent for retry.
KafkaConsumerBackoffManager	RetryTopicConfigurationSupport.kafkaConsumerBackoffManager(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler)	Create the KafkaConsumerBackoffManager instance that will be used to back off partitions.
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.