Package org.springframework.kafka.listener

Interface BackOffHandler

All Known Implementing Classes:

ContainerPausingBackOffHandler, DefaultBackOffHandler

public interface BackOffHandler

Handler for the provided back off time, listener container and exception. Also supports back off for individual partitions.

Since:

2.9

Author:

Jan Marincek, Gary Russell

Method Summary

Modifier and Type	Method	Description
default void	onNextBackOff(MessageListenerContainer container, Exception exception, long nextBackOff)	Perform the next back off.
default void	onNextBackOff(MessageListenerContainer container, org.apache.kafka.common.TopicPartition partition, long nextBackOff)	Perform the next back off for a partition.

Method Details

onNextBackOff

default void onNextBackOff(@Nullable
 MessageListenerContainer container,
 Exception exception,
 long nextBackOff)

Perform the next back off.

Parameters:

container - the container.

exception - the exception.

nextBackOff - the next back off.

onNextBackOff

default void onNextBackOff(MessageListenerContainer container,
 org.apache.kafka.common.TopicPartition partition,
 long nextBackOff)

Perform the next back off for a partition.

Parameters:

container - the container.

partition - the partition.

nextBackOff - the next back off.