Package org.springframework.kafka.listener

Class KafkaBackoffException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.springframework.core.NestedRuntimeException

org.springframework.kafka.KafkaException

org.springframework.kafka.listener.KafkaBackoffException

All Implemented Interfaces:

Serializable

public class KafkaBackoffException
extends KafkaException

Exception thrown when the consumer should not yet consume the message due to backOff.

Since:

2.7

Author:

Tomaz Fernandes

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.kafka.KafkaException

KafkaException.Level

Constructor Summary

Constructors

Constructor	Description
KafkaBackoffException(String message, org.apache.kafka.common.TopicPartition topicPartition, String listenerId, long dueTimestamp)	Constructor with data from the BackOff event.

Method Summary

Modifier and Type	Method	Description
long	getDueTimestamp()
String	getListenerId()
org.apache.kafka.common.TopicPartition	getTopicPartition()

Methods inherited from class org.springframework.kafka.KafkaException

selfLog

Methods inherited from class org.springframework.core.NestedRuntimeException

contains, getMostSpecificCause, getRootCause

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaBackoffException

public KafkaBackoffException(String message,
 org.apache.kafka.common.TopicPartition topicPartition,
 String listenerId,
 long dueTimestamp)

Constructor with data from the BackOff event.

Parameters:

message - the error message.

topicPartition - the partition that was backed off.

listenerId - the listenerId for the consumer that was backed off.

dueTimestamp - the time at which the message should be consumed.

Method Details

getListenerId

public String getListenerId()

getTopicPartition

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

getDueTimestamp

public long getDueTimestamp()