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 TypeClassDescriptionclassA 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 KafkaConsumerBackoffManagerAbstractKafkaBackOffManagerFactory.doCreateManager(ListenerContainerRegistry registry) protected KafkaConsumerBackoffManagerContainerPartitionPausingBackOffManagerFactory.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 theKafkaConsumerBackoffManagerinstance 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 aListenerContainerFactoryConfigurerthat will be used to configure theKafkaListenerContainerFactoryresolved by theListenerContainerFactoryResolver.RetryTopicConfigurationSupport.retryTopicConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) Return a globalRetryTopicConfigurerfor configuring retry topics forKafkaListenerEndpointinstances with a correspondingRetryTopicConfiguration.Constructors in org.springframework.kafka.retrytopic with parameters of type KafkaConsumerBackoffManagerModifierConstructorDescriptionListenerContainerFactoryConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, Clock clock)