Uses of Interface
org.springframework.kafka.listener.BackOffHandler

Packages that use BackOffHandler

Package	Description
org.springframework.kafka.listener	Package for kafka listeners

Uses of BackOffHandler in org.springframework.kafka.listener

Classes in org.springframework.kafka.listener that implement BackOffHandler

Modifier and Type	Class	Description
class	ContainerPausingBackOffHandler	A BackOffHandler that pauses the container for the requested back off period.
class	DefaultBackOffHandler	Default BackOffHandler; suspends the thread for the back off.

Methods in org.springframework.kafka.listener with parameters of type BackOffHandler

Modifier and Type	Method	Description
void	ContainerPartitionPausingBackOffManagerFactory.setBackOffHandler(BackOffHandler backOffHandler)	Set the back off handler to use in the created handlers.

Constructors in org.springframework.kafka.listener with parameters of type BackOffHandler

Modifier	Constructor	Description
	ContainerPartitionPausingBackOffManager(ListenerContainerRegistry listenerContainerRegistry, BackOffHandler backOffHandler)	Construct an instance with the provided registry and back off handler.
	DefaultAfterRollbackProcessor(@Nullable BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, Exception> recoverer, BackOff backOff, @Nullable BackOffHandler backOffHandler, @Nullable 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(@Nullable ConsumerRecordRecoverer recoverer, BackOff backOff, @Nullable BackOffHandler backOffHandler)	Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
	FailedBatchProcessor(@Nullable BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, Exception> recoverer, BackOff backOff, @Nullable BackOffHandler backOffHandler, CommonErrorHandler fallbackHandler)	Construct an instance with the provided properties.
protected	FailedRecordProcessor(@Nullable BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, Exception> recoverer, BackOff backOff, @Nullable BackOffHandler backOffHandler)