Interface BackOffHandler
-
- All Known Implementing Classes:
ContainerPausingBackOffHandler,DefaultBackOffHandler
public interface BackOffHandlerHandler 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
All Methods Instance Methods Default Methods Modifier and Type Method Description default voidonNextBackOff(MessageListenerContainer container, java.lang.Exception exception, long nextBackOff)Perform the next back off.default voidonNextBackOff(MessageListenerContainer container, org.apache.kafka.common.TopicPartition partition, long nextBackOff)Perform the next back off for a partition.
-
-
-
Method Detail
-
onNextBackOff
default void onNextBackOff(@Nullable MessageListenerContainer container, java.lang.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.
-
-