Package org.springframework.kafka.listener

Interface KafkaConsumerBackoffManager

All Known Implementing Classes:

ContainerPartitionPausingBackOffManager

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

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

Modifier and Type	Method	Description
void	backOffIfNecessary(KafkaConsumerBackoffManager.Context context)
default KafkaConsumerBackoffManager.Context	createContext(long dueTimestamp, String listenerId, org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.Consumer<?,?> messageConsumer)

Method Details

backOffIfNecessary

void backOffIfNecessary(KafkaConsumerBackoffManager.Context context)

createContext

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