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 TypeMethodDescriptiondefault voidonNextBackOff(MessageListenerContainer container, 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 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.
-