Uses of Interface
org.springframework.kafka.listener.BackOffHandler
Packages that use BackOffHandler
-
Uses of BackOffHandler in org.springframework.kafka.listener
Classes in org.springframework.kafka.listener that implement BackOffHandlerModifier and TypeClassDescriptionclassABackOffHandlerthat pauses the container for the backoff.classDefaultBackOffHandler; suspends the thread for the back off.Methods in org.springframework.kafka.listener with parameters of type BackOffHandlerModifier and TypeMethodDescriptionvoidContainerPartitionPausingBackOffManagerFactory.setBackOffHandler(BackOffHandler backOffHandler) Set the back off handler to use in the created handlers.Constructors in org.springframework.kafka.listener with parameters of type BackOffHandlerModifierConstructorDescriptionContainerPartitionPausingBackOffManager(ListenerContainerRegistry listenerContainerRegistry, BackOffHandler backOffHandler) Construct an instance with the provided registry and back off handler.DefaultAfterRollbackProcessor(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, BackOffHandler backOffHandler, KafkaOperations<?, ?> kafkaOperations, boolean commitRecovered) Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.DefaultErrorHandler(ConsumerRecordRecoverer recoverer, BackOff backOff, BackOffHandler backOffHandler) Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.FailedBatchProcessor(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, BackOffHandler backOffHandler, CommonErrorHandler fallbackHandler) Construct an instance with the provided properties.protectedFailedRecordProcessor(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, BackOffHandler backOffHandler)