Uses of Interface
org.springframework.kafka.listener.ListenerContainerRegistry
Package
Description
Package for kafka configuration
Package for kafka listeners
Package for retryable topic handling.
-
Uses of ListenerContainerRegistry in org.springframework.kafka.config
Modifier and TypeClassDescriptionclass
Creates the necessaryMessageListenerContainer
instances for the registered endpoints. -
Uses of ListenerContainerRegistry in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected ListenerContainerRegistry
AbstractKafkaBackOffManagerFactory.getListenerContainerRegistry()
Modifier 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.ModifierConstructorDescriptionAbstractKafkaBackOffManagerFactory
(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
Modifier 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.