Struct MemberMetadata 

pub struct MemberMetadata {
    pub id: String,
    pub group_instance_id: String,
    pub client_id: String,
    pub client_host: String,
    pub rebalance_timeout: i32,
    pub session_timeout: i32,
    pub subscription: ConsumerProtocolSubscription,
    pub assignment: ConsumerProtocolAssignment,
}

Metadata for a Consumer Group Member.

Note that the words “Member” and “Consumer” can be used interchangeably in this context.

Fields

id: String

Consumer Group Member identifier.

group_instance_id: String

Member Group Instance identifier.

client_id: String

Consumer Client identifier.

This corresponds to the Kafka (client) configuration option client.id.

client_host: String

Consumer Client host.

Usually its IP.

rebalance_timeout: i32

Maximum time (ms) that Group Coordinator will wait for member to rejoin when rebalancing the GroupMetadata::group.

session_timeout: i32

Group Coordinator considers member (i.e. consumer) “dead” if it receives no heartbeat after this timeout (ms).

If the container GroupMetadata::schema_version is 0, this is used by the Group Coordinator in place of Self::rebalance_timeout.

subscription: ConsumerProtocolSubscription

Consumer topic and partition subscriptions.

This is what the consumer explicitly subscribes to: either this or assignment is populated, but usually not both.

assignment: ConsumerProtocolAssignment

Consumer partition assignment by the [Group Coordinator].

This is what the consumer is assigned by the [Group Coordinator]: either this or subscription is populated, but usually not both.

Trait Implementations

impl Clone for MemberMetadata

fn clone(&self) -> MemberMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemberMetadata

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

Formats the value using the given formatter.

impl Default for MemberMetadata

fn default() -> MemberMetadata

Returns the “default value” for a type.

impl PartialEq for MemberMetadata

fn eq(&self, other: &MemberMetadata) -> 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 Eq for MemberMetadata

impl StructuralPartialEq for MemberMetadata