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(@Nullable MessageListenerContainer container, @Nullable 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, @Nullable 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.