Struct Subscription 

pub struct Subscription {
    pub member_id: String,
    pub topics: Vec<String>,
    pub owned: Vec<TopicPartition>,
    pub generation: i32,
}

One member’s declared interest, as it arrives in JoinGroup.

Fields

member_id: String

topics: Vec<String>

Topics this member wants. Order is not significant; assignors sort.

owned: Vec<TopicPartition>

What this member holds now, for assignors that try to keep it. Empty for the stateless strategies.

generation: i32

The generation owned was true in, or -1 if the member did not say.

This is what makes an ownership claim trustworthy. A member that was away still advertises the partitions it used to hold, and a leader that believes it will hand the same partition to two members at once. Kafka added the field to ConsumerProtocolSubscription v2 for exactly this, and the rule every client applies is the same: a claim from below the highest generation in the group is stale and is ignored.

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Subscription

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

Formats the value using the given formatter.

impl Eq for Subscription

impl PartialEq for Subscription

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Subscription