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:
java.io.Serializable
public class KafkaBackoffException extends KafkaException
Exception thrown when the consumer should not yet consume the message due to backOff.- Since:
- 2.7
- 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(java.lang.String message, org.apache.kafka.common.TopicPartition topicPartition, java.lang.String listenerId, long dueTimestamp)Constructor with data from the BackOff event.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetDueTimestamp()java.lang.StringgetListenerId()org.apache.kafka.common.TopicPartitiongetTopicPartition()-
Methods inherited from class org.springframework.kafka.KafkaException
selfLog
-
Methods inherited from class org.springframework.core.NestedRuntimeException
contains, getMessage, getMostSpecificCause, getRootCause
-
-
-
-
Constructor Detail
-
KafkaBackoffException
public KafkaBackoffException(java.lang.String message, org.apache.kafka.common.TopicPartition topicPartition, java.lang.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.
-
-