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
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:
-
Constructor Summary
ConstructorDescriptionOffsetOutOfRangeException
(String message, Map<TopicPartition, Long> offsetOutOfRangePartitions) OffsetOutOfRangeException
(Map<TopicPartition, Long> offsetOutOfRangePartitions) -
Method Summary
Modifier and TypeMethodDescriptionGet a map of the topic partitions and the respective out-of-range fetch offsets.Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
Constructor Details
-
OffsetOutOfRangeException
-
OffsetOutOfRangeException
public OffsetOutOfRangeException(String message, Map<TopicPartition, Long> offsetOutOfRangePartitions)
-
-
Method Details
-
offsetOutOfRangePartitions
Get a map of the topic partitions and the respective out-of-range fetch offsets. -
partitions
- Specified by:
partitions
in classInvalidOffsetException
-