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 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.
-