Struct ConsumerGroupOffsetQuery 

pub struct ConsumerGroupOffsetQuery { /* private fields */ }

A topic and partition filter for consumer-group offset inspection.

Implementations

impl ConsumerGroupOffsetQuery

pub fn new( topic: impl Into<String>, partitions: impl IntoIterator<Item = i32>, ) -> Self

Creates an offset query for one topic.

pub fn topic(&self) -> &str

Returns the topic name.

pub fn partitions(&self) -> &[i32]

Returns partition indexes in request order.

Trait Implementations

impl Clone for ConsumerGroupOffsetQuery

fn clone(&self) -> ConsumerGroupOffsetQuery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerGroupOffsetQuery

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

Formats the value using the given formatter.

impl Eq for ConsumerGroupOffsetQuery

impl PartialEq for ConsumerGroupOffsetQuery

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerGroupOffsetQuery