Struct ConsumerOffsetOutOfRangeError 

pub struct ConsumerOffsetOutOfRangeError { /* private fields */ }

A fetch asked for an offset outside the range the broker retains.

Corresponds to Java’s org.apache.kafka.clients.consumer.OffsetOutOfRangeException. It has no entry in Errors, so it carries no protocol code — the wire code OFFSET_OUT_OF_RANGE builds the common.errors class instead.

Java extends chain: OffsetOutOfRangeException -> InvalidOffsetException -> KafkaException

Implementations

impl ConsumerOffsetOutOfRangeError

pub fn new(offset_out_of_range_partitions: HashMap<TopicPartition, i64>) -> Self

Create the error, mirroring Java’s OffsetOutOfRangeException(Map<TopicPartition, Long>).

pub fn with_message( message: impl Into<String>, offset_out_of_range_partitions: HashMap<TopicPartition, i64>, ) -> Self

Create the error with a caller-supplied message, mirroring Java’s OffsetOutOfRangeException(String, Map<TopicPartition, Long>).

pub fn offset_out_of_range_partitions(&self) -> &HashMap<TopicPartition, i64>

The out-of-range offset per partition.

pub fn partitions(&self) -> impl Iterator<Item = &TopicPartition>

The partitions this error covers.

Mirrors Java’s OffsetOutOfRangeException.partitions() (OffsetOutOfRangeException.java:51-54), which is return offsetOutOfRangePartitions.keySet(); — the override of the single abstract member InvalidOffsetException declares (InvalidOffsetException.java:36), so it is available uniformly across the family that is_consumer_invalid_offset_error recognises.

Returns an iterator rather than a HashSet: Java’s keySet() is a view over the map, so materialising a set here would allocate where Java does not (CLAUDE.md §13/§14).

pub fn message(&self) -> &str

The error message.

impl ConsumerOffsetOutOfRangeError

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

The underlying source, if any. Mirrors Java’s getCause() (OffsetOutOfRangeException(String, Throwable)).

Trait Implementations

impl Clone for ConsumerOffsetOutOfRangeError

fn clone(&self) -> ConsumerOffsetOutOfRangeError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerOffsetOutOfRangeError

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

Formats the value using the given formatter.

impl Display for ConsumerOffsetOutOfRangeError

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

Formats the value using the given formatter.

impl Error for ConsumerOffsetOutOfRangeError

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.