Uses of Interface
org.springframework.kafka.listener.KafkaConsumerTimingAdjuster
Packages that use KafkaConsumerTimingAdjuster
-
Uses of KafkaConsumerTimingAdjuster in org.springframework.kafka.listener
Classes in org.springframework.kafka.listener that implement KafkaConsumerTimingAdjusterModifier and TypeClassDescriptionclassAdjusts timing by creating a thread that will wakeup the consumer from polling, considering that, if consumption is paused, it will check for consumption resuming in increments of 'pollTimeout'.Methods in org.springframework.kafka.listener with parameters of type KafkaConsumerTimingAdjusterModifier and TypeMethodDescriptionfinal voidPartitionPausingBackOffManagerFactory.setTimingAdjustmentManager(KafkaConsumerTimingAdjuster timingAdjustmentManager) Sets theWakingKafkaConsumerTimingAdjusterthat will be used with the resultingKafkaConsumerBackoffManager.Constructors in org.springframework.kafka.listener with parameters of type KafkaConsumerTimingAdjusterModifierConstructorDescriptionPartitionPausingBackoffManager(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(KafkaConsumerTimingAdjuster timingAdjustmentManager) Constructs a factory instance that will create theKafkaConsumerBackoffManagerinstances with the providedKafkaConsumerTimingAdjuster.