Struct ConsumerGroupMetadata 

pub struct ConsumerGroupMetadata {
    pub group_id: String,
    pub generation_id: i32,
    pub member_id: String,
    pub group_instance_id: Option<String>,
}

The identity a consumer presents to a transactional producer for KIP-447 offset-commit fencing. Mirrors the JVM’s org.apache.kafka.clients.consumer.ConsumerGroupMetadata.

Fields

group_id: String

The consumer group id.

generation_id: i32

Classic-group generation id, or — for a KIP-848 next-gen group — the member epoch. Sent verbatim in TxnOffsetCommitRequest.generation_id (matches the JVM wire convention); the coordinator interprets it per group kind.

member_id: String

The member id assigned by the coordinator at join time. Empty for a simple consumer (manual assignment, no group membership).

group_instance_id: Option<String>

group.instance.id for static members; None for dynamic members.

Implementations

impl ConsumerGroupMetadata

pub fn for_group(group_id: impl Into<String>) -> Self

Metadata for a producer committing offsets to a group it is not a member of (manual partition assignment / simple consumer). The group coordinator applies no generation/member fencing to this shape.

Trait Implementations

impl Clone for ConsumerGroupMetadata

fn clone(&self) -> ConsumerGroupMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerGroupMetadata

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

Formats the value using the given formatter.

impl Eq for ConsumerGroupMetadata

impl PartialEq for ConsumerGroupMetadata

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ConsumerGroupMetadata