Uses of Interface
org.springframework.kafka.listener.KafkaConsumerBackoffManager
Packages that use KafkaConsumerBackoffManager
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
Package for retryable topic handling.
-
Uses of KafkaConsumerBackoffManager in org.springframework.kafka.listener
Classes in org.springframework.kafka.listener that implement KafkaConsumerBackoffManagerModifier and TypeClassDescriptionclass
A manager that backs off consumption for a given topic if the timestamp provided is not due.Methods in org.springframework.kafka.listener that return KafkaConsumerBackoffManagerModifier and TypeMethodDescriptionAbstractKafkaBackOffManagerFactory.create()
KafkaBackOffManagerFactory.create()
protected abstract KafkaConsumerBackoffManager
AbstractKafkaBackOffManagerFactory.doCreateManager
(ListenerContainerRegistry registry) protected KafkaConsumerBackoffManager
ContainerPartitionPausingBackOffManagerFactory.doCreateManager
(ListenerContainerRegistry registry) -
Uses of KafkaConsumerBackoffManager in org.springframework.kafka.listener.adapter
Constructors in org.springframework.kafka.listener.adapter with parameters of type KafkaConsumerBackoffManagerModifierConstructorDescriptionKafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> delegate, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, String listenerId, String backoffTimestampHeader, Clock clock) The configuration for this listener adapter.KafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> adapter, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, String listenerId, Clock clock) -
Uses of KafkaConsumerBackoffManager in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return KafkaConsumerBackoffManagerModifier and TypeMethodDescriptionRetryTopicConfigurationSupport.kafkaConsumerBackoffManager
(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler) Create theKafkaConsumerBackoffManager
instance that will be used to back off partitions.Methods in org.springframework.kafka.retrytopic with parameters of type KafkaConsumerBackoffManagerModifier and TypeMethodDescriptionRetryTopicComponentFactory.listenerContainerFactoryConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, Clock clock) Create aListenerContainerFactoryConfigurer
that will be used to configure theKafkaListenerContainerFactory
resolved by theListenerContainerFactoryResolver
.RetryTopicConfigurationSupport.retryTopicConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) Return a globalRetryTopicConfigurer
for configuring retry topics forKafkaListenerEndpoint
instances with a correspondingRetryTopicConfiguration
.Constructors in org.springframework.kafka.retrytopic with parameters of type KafkaConsumerBackoffManagerModifierConstructorDescriptionListenerContainerFactoryConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, Clock clock)