Class OffsetOutOfRangeException
- java.lang.Object
-
- java.lang.Throwable
-
- java.lang.Exception
-
- java.lang.RuntimeException
-
- org.apache.kafka.common.KafkaException
-
- org.apache.kafka.clients.consumer.InvalidOffsetException
-
- org.apache.kafka.clients.consumer.OffsetOutOfRangeException
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
LogTruncationException
public class OffsetOutOfRangeException extends InvalidOffsetException
No reset policy has been defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description OffsetOutOfRangeException(String message, Map<TopicPartition,Long> offsetOutOfRangePartitions)
OffsetOutOfRangeException(Map<TopicPartition,Long> offsetOutOfRangePartitions)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<TopicPartition,Long>
offsetOutOfRangePartitions()
Get a map of the topic partitions and the respective out-of-range fetch offsets.Set<TopicPartition>
partitions()
-
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
-
-
-
Constructor Detail
-
OffsetOutOfRangeException
public OffsetOutOfRangeException(Map<TopicPartition,Long> offsetOutOfRangePartitions)
-
OffsetOutOfRangeException
public OffsetOutOfRangeException(String message, Map<TopicPartition,Long> offsetOutOfRangePartitions)
-
-
Method Detail
-
offsetOutOfRangePartitions
public Map<TopicPartition,Long> offsetOutOfRangePartitions()
Get a map of the topic partitions and the respective out-of-range fetch offsets.
-
partitions
public Set<TopicPartition> partitions()
- Specified by:
partitions
in classInvalidOffsetException
-
-