Package org.apache.kafka.clients.consumer

Class OffsetOutOfRangeException

  • All Implemented Interfaces:
    java.io.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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Map<TopicPartition,​java.lang.Long> offsetOutOfRangePartitions()
      Get a map of the topic partitions and the respective out-of-range fetch offsets.
      java.util.Set<TopicPartition> partitions()  

      • 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 Detail

      • OffsetOutOfRangeException

        public OffsetOutOfRangeException​(java.util.Map<TopicPartition,​java.lang.Long> offsetOutOfRangePartitions)

      • OffsetOutOfRangeException

        public OffsetOutOfRangeException​(java.lang.String message,
                                 java.util.Map<TopicPartition,​java.lang.Long> offsetOutOfRangePartitions)

    • Method Detail

      • offsetOutOfRangePartitions

        public java.util.Map<TopicPartition,​java.lang.Long> offsetOutOfRangePartitions()
        Get a map of the topic partitions and the respective out-of-range fetch offsets.