Struct ConsumerNoOffsetForPartitionError 

pub struct ConsumerNoOffsetForPartitionError { /* private fields */ }

No offset is defined for one or more partitions and no reset policy is set.

Corresponds to Java’s NoOffsetForPartitionException. It has no entry in Errors, so it carries no protocol code.

Java extends chain: NoOffsetForPartitionException -> InvalidOffsetException -> KafkaException

The InvalidOffsetException here is the consumer package’s abstract class, which extends KafkaException — not the concrete InvalidOffsetError of common.errors, which extends ApiException. Hence is_consumer_invalid_offset_error rather than is_invalid_offset_error.

Implementations

impl ConsumerNoOffsetForPartitionError

pub fn new(partition: TopicPartition) -> Self

Create the error for a single partition, mirroring Java’s NoOffsetForPartitionException(TopicPartition).

Java’s single-partition constructor renders the singular “partition:” while the collection constructor renders “partitions:”; both forms are asserted by tests, so they are built separately rather than routed through one another.

pub fn for_partitions( partitions: impl IntoIterator<Item = TopicPartition>, ) -> Self

Create the error for a set of partitions, mirroring Java’s NoOffsetForPartitionException(Collection<TopicPartition>).

pub fn partitions(&self) -> &HashSet<TopicPartition>

The partitions with no defined offset.

pub fn message(&self) -> &str

The error message.

impl ConsumerNoOffsetForPartitionError

pub fn source(&self) -> Option<&Error>

Always None: NoOffsetForPartitionException exposes no Throwable cause constructor, so its cause is null in Java too. Present as an inherent method so it shadows both ErrorSource::source and std::error::Error::source, keeping x.source() unambiguous and typed.

Trait Implementations

impl Clone for ConsumerNoOffsetForPartitionError

fn clone(&self) -> ConsumerNoOffsetForPartitionError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumerNoOffsetForPartitionError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for ConsumerNoOffsetForPartitionError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for ConsumerNoOffsetForPartitionError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.