Struct ConsumerAssignment 

pub struct ConsumerAssignment { /* private fields */ }

Direct consumer topic partition assignment.

Implementations

impl ConsumerAssignment

pub fn topic(&self) -> &str

Returns the Kafka topic name.

pub fn partition(&self) -> i32

Returns the Kafka partition index.

pub fn next_offset(&self) -> i64

Returns the next offset that will be fetched or committed.

pub fn leader_epoch(&self) -> i32

Returns the latest partition leader epoch observed by this assignment.

The initial value is -1 until a RecordBatch response provides an epoch. Legacy MessageSet responses do not update this value.

pub fn is_paused(&self) -> bool

Returns whether fetching is paused for this assignment.

Trait Implementations

impl Clone for ConsumerAssignment

fn clone(&self) -> ConsumerAssignment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerAssignment

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

Formats the value using the given formatter.

impl Eq for ConsumerAssignment

impl PartialEq for ConsumerAssignment

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerAssignment