Uses of Interface
org.springframework.kafka.listener.ListenerContainerRegistry
Packages that use ListenerContainerRegistry
Package
Description
Package for kafka configuration
Package for kafka listeners
Package for retryable topic handling.
-
Uses of ListenerContainerRegistry in org.springframework.kafka.config
Classes in org.springframework.kafka.config that implement ListenerContainerRegistryModifier and TypeClassDescriptionclass
Creates the necessaryMessageListenerContainer
instances for the registered endpoints. -
Uses of ListenerContainerRegistry in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return ListenerContainerRegistryModifier and TypeMethodDescriptionprotected ListenerContainerRegistry
AbstractKafkaBackOffManagerFactory.getListenerContainerRegistry()
Methods in org.springframework.kafka.listener with parameters of type ListenerContainerRegistryModifier and TypeMethodDescriptionprotected abstract KafkaConsumerBackoffManager
AbstractKafkaBackOffManagerFactory.doCreateManager
(ListenerContainerRegistry registry) protected KafkaConsumerBackoffManager
ContainerPartitionPausingBackOffManagerFactory.doCreateManager
(ListenerContainerRegistry registry) void
AbstractKafkaBackOffManagerFactory.setListenerContainerRegistry
(ListenerContainerRegistry listenerContainerRegistry) Sets theListenerContainerRegistry
, that will be used to fetch theMessageListenerContainer
to back off.Constructors in org.springframework.kafka.listener with parameters of type ListenerContainerRegistryModifierConstructorDescriptionAbstractKafkaBackOffManagerFactory
(ListenerContainerRegistry listenerContainerRegistry) Creates an instance with the providedListenerContainerRegistry
, which will be used to fetch theMessageListenerContainer
to back off.ContainerGroupSequencer
(ListenerContainerRegistry registry, long defaultIdleEventInterval, String... containerGroups) Set containers in each group to not auto start.ContainerPartitionPausingBackOffManager
(ListenerContainerRegistry listenerContainerRegistry, BackOffHandler backOffHandler) Construct an instance with the provided registry and back off handler.ContainerPartitionPausingBackOffManagerFactory
(ListenerContainerRegistry listenerContainerRegistry, ApplicationContext applicationContext) Construct an instance with the provided properties.ListenerContainerPauseService
(ListenerContainerRegistry registry, TaskScheduler scheduler) Create an instance with the provided registry and scheduler. -
Uses of ListenerContainerRegistry in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic with parameters of type ListenerContainerRegistryModifier and TypeMethodDescriptionRetryTopicComponentFactory.kafkaBackOffManagerFactory
(ListenerContainerRegistry registry, ApplicationContext applicationContext) Create theKafkaBackOffManagerFactory
that will be used to create theKafkaConsumerBackoffManager
instance used to back off the partitions.RetryTopicConfigurationSupport.kafkaConsumerBackoffManager
(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler) Create theKafkaConsumerBackoffManager
instance that will be used to back off partitions.