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