Interface KafkaConsumerBackoffManager
-
- All Known Implementing Classes:
PartitionPausingBackoffManager
public interface KafkaConsumerBackoffManagerInterface for backing off aMessageListenerContaineruntil 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 classKafkaConsumerBackoffManager.ContextProvides the state that will be used for backing off.
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidbackOffIfNecessary(KafkaConsumerBackoffManager.Context context)default KafkaConsumerBackoffManager.ContextcreateContext(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)
-
-