Interface KafkaConsumerBackoffManager

  • All Known Implementing Classes:
    PartitionPausingBackoffManager

    public interface KafkaConsumerBackoffManager
    Interface for backing off a MessageListenerContainer until a given dueTimestamp, if such timestamp is in the future.
    Since:
    2.7
    Author:
    Tomaz Fernandes, Gary Russell
    • Method Detail

      • createContext

        default KafkaConsumerBackoffManager.Context createContext​(long dueTimestamp,
                                                                  java.lang.String listenerId,
                                                                  org.apache.kafka.common.TopicPartition topicPartition,
                                                                  @Nullable
                                                                  org.apache.kafka.clients.consumer.Consumer<?,​?> messageConsumer)