Uses of Interface
org.springframework.kafka.listener.BackOffHandler
-
Uses of BackOffHandler in org.springframework.kafka.listener
Modifier and TypeClassDescriptionclass
ABackOffHandler
that pauses the container for the backoff.class
DefaultBackOffHandler
; suspends the thread for the back off.Modifier and TypeMethodDescriptionvoid
ContainerPartitionPausingBackOffManagerFactory.setBackOffHandler
(BackOffHandler backOffHandler) Set the back off handler to use in the created handlers.ModifierConstructorDescriptionContainerPartitionPausingBackOffManager
(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.protected
FailedRecordProcessor
(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, BackOffHandler backOffHandler)