Struct ShareGroupOffsetPartitionResult 

pub struct ShareGroupOffsetPartitionResult { /* private fields */ }

Result for one partition returned by DescribeShareGroupOffsets.

Implementations

impl ShareGroupOffsetPartitionResult

pub fn partition(&self) -> i32

Returns the partition index.

pub fn start_offset(&self) -> i64

Returns the share-partition start offset.

pub fn leader_epoch(&self) -> i32

Returns the leader epoch, or Kafka’s sentinel when unavailable.

pub fn lag(&self) -> Option<i64>

Returns the partition lag when the broker supplied it.

pub fn error_code(&self) -> i16

Returns the partition-level Kafka error code.

pub fn error_message(&self) -> Option<&str>

Returns the partition-level error message, when supplied.

pub fn is_success(&self) -> bool

Returns whether Kafka returned this partition without an error.

Trait Implementations

impl Clone for ShareGroupOffsetPartitionResult

fn clone(&self) -> ShareGroupOffsetPartitionResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShareGroupOffsetPartitionResult

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

Formats the value using the given formatter.

impl Eq for ShareGroupOffsetPartitionResult

impl PartialEq for ShareGroupOffsetPartitionResult

fn eq(&self, other: &ShareGroupOffsetPartitionResult) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ShareGroupOffsetPartitionResult