org.apache.kafka.clients.consumer.NoOffsetForPartitionException

public class NoOffsetForPartitionExceptionextends InvalidOffsetException

Indicates that there is no stored offset for a partition and no defined offset reset policy.

See Also:

Constructor Details
- NoOffsetForPartitionException
  public NoOffsetForPartitionException(TopicPartition partition)
- NoOffsetForPartitionException
  public NoOffsetForPartitionException(Collection<TopicPartition> partitions)
Method Details
- partitions
  public Set<TopicPartition> partitions()
  returns all partitions for which no offsets are defined.
  Specified by:
  partitions in class InvalidOffsetException
  Returns:
  all partitions without offsets

Class NoOffsetForPartitionException

Constructor Summary