Package org.springframework.kafka.listener

Class KafkaConsumerBackoffManager.Context

java.lang.Object

org.springframework.kafka.listener.KafkaConsumerBackoffManager.Context

Enclosing interface:

KafkaConsumerBackoffManager

public static class KafkaConsumerBackoffManager.Context
extends Object

Provides the state that will be used for backing off.

Since:

2.7

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.consumer.Consumer<?,?>	getConsumerForTimingAdjustment()
long	getDueTimestamp()
String	getListenerId()
org.apache.kafka.common.TopicPartition	getTopicPartition()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getDueTimestamp

public long getDueTimestamp()

getListenerId

public String getListenerId()

getTopicPartition

public org.apache.kafka.common.TopicPartition getTopicPartition()

getConsumerForTimingAdjustment

public org.apache.kafka.clients.consumer.Consumer<?,?> getConsumerForTimingAdjustment()