public class OffsetOutOfRangeException extends InvalidOffsetException
Constructor and Description |
---|
OffsetOutOfRangeException(Map<TopicPartition,Long> offsetOutOfRangePartitions) |
OffsetOutOfRangeException(String message,
Map<TopicPartition,Long> offsetOutOfRangePartitions) |
Modifier and Type | Method and Description |
---|---|
Map<TopicPartition,Long> |
offsetOutOfRangePartitions()
Get a map of the topic partitions and the respective out-of-range fetch offsets.
|
Set<TopicPartition> |
partitions() |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
public OffsetOutOfRangeException(Map<TopicPartition,Long> offsetOutOfRangePartitions)
public OffsetOutOfRangeException(String message, Map<TopicPartition,Long> offsetOutOfRangePartitions)
public Map<TopicPartition,Long> offsetOutOfRangePartitions()
public Set<TopicPartition> partitions()
partitions
in class InvalidOffsetException