Class NoOffsetForPartitionException
- 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.NoOffsetForPartitionException
 
 
 
 
 
 
 
- 
- All Implemented Interfaces:
 Serializable
public class NoOffsetForPartitionException extends InvalidOffsetException
Indicates that there is no stored offset for a partition and no defined offset reset policy.- See Also:
 - Serialized Form
 
 
- 
- 
Constructor Summary
Constructors Constructor Description NoOffsetForPartitionException(Collection<TopicPartition> partitions)NoOffsetForPartitionException(TopicPartition partition) 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Set<TopicPartition>partitions()returns all partitions for which no offsets are defined.- 
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString 
 - 
 
 - 
 
- 
- 
Constructor Detail
- 
NoOffsetForPartitionException
public NoOffsetForPartitionException(TopicPartition partition)
 
- 
NoOffsetForPartitionException
public NoOffsetForPartitionException(Collection<TopicPartition> partitions)
 
 - 
 
- 
Method Detail
- 
partitions
public Set<TopicPartition> partitions()
returns all partitions for which no offsets are defined.- Specified by:
 partitionsin classInvalidOffsetException- Returns:
 - all partitions without offsets
 
 
 - 
 
 -