Interface KafkaConsumerBackoffManager
-
- All Known Implementing Classes:
PartitionPausingBackoffManager
public interface KafkaConsumerBackoffManager
Interface for backing off aMessageListenerContainer
until a given dueTimestamp, if such timestamp is in the future.- Since:
- 2.7
- Author:
- Tomaz Fernandes, Gary Russell
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
KafkaConsumerBackoffManager.Context
Provides the state that will be used for backing off.
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
backOffIfNecessary(KafkaConsumerBackoffManager.Context context)
default KafkaConsumerBackoffManager.Context
createContext(long dueTimestamp, java.lang.String listenerId, org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.Consumer<?,?> messageConsumer)
-
-
-
Method Detail
-
backOffIfNecessary
void backOffIfNecessary(KafkaConsumerBackoffManager.Context context)
-
createContext
default KafkaConsumerBackoffManager.Context createContext(long dueTimestamp, java.lang.String listenerId, org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.Consumer<?,?> messageConsumer)
-
-