Struct ShareGroupMember 

pub struct ShareGroupMember {
    pub member_id: String,
    pub rack_id: Option<String>,
    pub member_epoch: i32,
    pub client_id: String,
    pub client_host: String,
    pub subscribed_topic_names: Vec<String>,
    pub assignment: ShareGroupAssignment,
}

One member in a ShareGroupDescribe v0–v1 group.

Java ShareMemberDescription. Official member fields are MemberId, RackId, MemberEpoch, ClientId, ClientHost, SubscribedTopicNames, Assignment. There is no InstanceId, SubscribedTopicRegex, TargetAssignment, or MemberType.

std::fmt::Display is Java ShareMemberDescription.toString (memberId, clientId, host, assignment; omits rack, epoch, and subscriptions).

Fields

member_id: String

Group member id.

rack_id: Option<String>

Client rack, when known.

member_epoch: i32

Member epoch (KIP-848 / share).

client_id: String

Kafka client.id.

client_host: String

Client host as seen by the broker.

subscribed_topic_names: Vec<String>

Subscribed topic names.

assignment: ShareGroupAssignment

Assigned partitions for this member.

Implementations

impl ShareGroupMember

pub fn new( member_id: impl Into<String>, member_epoch: i32, client_id: impl Into<String>, client_host: impl Into<String>, ) -> Self

Construct Self.

pub fn member_id(&self) -> &str

Java ShareMemberDescription.consumerId.

pub fn client_id(&self) -> &str

Java ShareMemberDescription.clientId.

pub fn host(&self) -> &str

Java ShareMemberDescription.host.

pub fn assignment(&self) -> &ShareGroupAssignment

Java ShareMemberDescription.assignment.

Trait Implementations

impl Clone for ShareGroupMember

fn clone(&self) -> ShareGroupMember

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShareGroupMember

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

Formats the value using the given formatter.

impl Display for ShareGroupMember

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

Formats the value using the given formatter.

impl Eq for ShareGroupMember

impl PartialEq for ShareGroupMember

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ShareGroupMember