Struct ConsumerOffsetOutOfRangeError 

pub struct ConsumerOffsetOutOfRangeError { /* private fields */ }

No reset policy has been defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition.

Implementations

impl ConsumerOffsetOutOfRangeError

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

Constructs a new ConsumerOffsetOutOfRangeError with the offsets that are out of range.

Arguments

• offset_out_of_range_partitions - Map of partition to the out-of-range offset

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

Constructs a new ConsumerOffsetOutOfRangeError with a custom message.

Arguments

• message - The detail message
• offset_out_of_range_partitions - Map of partition to the out-of-range offset

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

Get a map of the topic partitions and the respective out-of-range fetch offsets.

Returns

The out-of-range fetch offset per partition

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

Returns the set of partitions for which the offset was invalid.

Returns

The set of partitions with invalid offsets

Translation notes

Iterates the keys instead of copying them.

pub fn message(&self) -> &str

Returns the error message.

impl ConsumerOffsetOutOfRangeError

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

Returns the cause of this error, if any.

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.