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_id(self, topic_id: [u8; 16]) -> Self

Associates the stable Kafka topic UUID used by OffsetFetch v10.

A zero UUID is ignored for explicit version selection. The member-aware Admin method may resolve the topic name through Metadata v12; if that capability is unavailable, it uses the name-based OffsetFetch v9 path.

pub fn topic(&self) -> &str

Returns the topic name.

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

Returns partition indexes in request order.

pub fn topic_id_ref(&self) -> Option<[u8; 16]>

Returns the optional topic UUID used for OffsetFetch v10.

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