Uses of Interface
org.springframework.kafka.listener.ListenerContainerRegistry
Packages that use ListenerContainerRegistry
Package
Description
Package for kafka configuration
Package for kafka listeners
-
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
PartitionPausingBackOffManagerFactory.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.PartitionPausingBackoffManager
(ListenerContainerRegistry listenerContainerRegistry) Constructs an instance with the providedListenerContainerRegistry
and with no timing adjustment capabilities.PartitionPausingBackoffManager
(ListenerContainerRegistry listenerContainerRegistry, Clock clock) Creates an instance with the providedListenerContainerRegistry
andClock
, with no timing adjustment capabilities.PartitionPausingBackoffManager
(ListenerContainerRegistry listenerContainerRegistry, KafkaConsumerTimingAdjuster kafkaConsumerTimingAdjuster) Constructs an instance with the providedListenerContainerRegistry
andKafkaConsumerTimingAdjuster
.PartitionPausingBackoffManager
(ListenerContainerRegistry listenerContainerRegistry, KafkaConsumerTimingAdjuster kafkaConsumerTimingAdjuster, Clock clock) Creates an instance with the providedListenerContainerRegistry
,KafkaConsumerTimingAdjuster
andClock
.PartitionPausingBackOffManagerFactory
(ListenerContainerRegistry listenerContainerRegistry) Constructs a factory instance using the providedListenerContainerRegistry
.