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 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 KafkaConsumerBackoffManagerPartitionPausingBackOffManagerFactory.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.PartitionPausingBackoffManager(ListenerContainerRegistry listenerContainerRegistry) Constructs an instance with the providedListenerContainerRegistryand with no timing adjustment capabilities.PartitionPausingBackoffManager(ListenerContainerRegistry listenerContainerRegistry, Clock clock) Creates an instance with the providedListenerContainerRegistryandClock, with no timing adjustment capabilities.PartitionPausingBackoffManager(ListenerContainerRegistry listenerContainerRegistry, KafkaConsumerTimingAdjuster kafkaConsumerTimingAdjuster) Constructs an instance with the providedListenerContainerRegistryandKafkaConsumerTimingAdjuster.PartitionPausingBackoffManager(ListenerContainerRegistry listenerContainerRegistry, KafkaConsumerTimingAdjuster kafkaConsumerTimingAdjuster, Clock clock) Creates an instance with the providedListenerContainerRegistry,KafkaConsumerTimingAdjusterandClock.PartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry) Constructs a factory instance using the providedListenerContainerRegistry.