Uses of Class
org.springframework.kafka.retrytopic.RetryTopicComponentFactory
-
Uses of RetryTopicComponentFactory in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionprotected RetryTopicComponentFactory
RetryTopicConfigurationSupport.createComponentFactory()
Override this method to provide a subclass ofRetryTopicComponentFactory
with different component implementations or subclasses.Modifier and TypeMethodDescriptionRetryTopicConfigurationSupport.destinationTopicResolver
(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider) Return a globalDestinationTopicResolver
for resolving theDestinationTopic
to which a givenConsumerRecord
should be sent for retry.RetryTopicConfigurationSupport.kafkaConsumerBackoffManager
(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler) Create theKafkaConsumerBackoffManager
instance that will be used to back off partitions.RetryTopicConfigurationSupport.retryTopicConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) Return a globalRetryTopicConfigurer
for configuring retry topics forKafkaListenerEndpoint
instances with a correspondingRetryTopicConfiguration
.