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 TypeClassDescriptionclassCreates the necessaryMessageListenerContainerinstances for the registered endpoints. -
Uses of ListenerContainerRegistry in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return ListenerContainerRegistryModifier and TypeMethodDescriptionprotected ListenerContainerRegistryAbstractKafkaBackOffManagerFactory.getListenerContainerRegistry()Methods in org.springframework.kafka.listener with parameters of type ListenerContainerRegistryModifier and TypeMethodDescriptionprotected abstract KafkaConsumerBackoffManagerAbstractKafkaBackOffManagerFactory.doCreateManager(ListenerContainerRegistry registry) protected KafkaConsumerBackoffManagerContainerPartitionPausingBackOffManagerFactory.doCreateManager(ListenerContainerRegistry registry) voidAbstractKafkaBackOffManagerFactory.setListenerContainerRegistry(ListenerContainerRegistry listenerContainerRegistry) Sets theListenerContainerRegistry, that will be used to fetch theMessageListenerContainerto 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 theMessageListenerContainerto 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 theKafkaBackOffManagerFactorythat will be used to create theKafkaConsumerBackoffManagerinstance used to back off the partitions.RetryTopicConfigurationSupport.kafkaConsumerBackoffManager(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler) Create theKafkaConsumerBackoffManagerinstance that will be used to back off partitions.