Struct ConsumerProtocolSubscriptionV1 

pub struct ConsumerProtocolSubscriptionV1 {
    pub topics: Vec<String>,
    pub user_data: Option<Vec<u8>>,
    pub owned_partitions: Vec<ConsumerProtocolTopicAssignment>,
}

Consumer protocol subscription version 1 with previously owned partitions.

Kafka added OwnedPartitions in version 1 so cooperative assignors can stage ownership transfers across rebalances.

Fields

topics: Vec<String>

user_data: Option<Vec<u8>>

owned_partitions: Vec<ConsumerProtocolTopicAssignment>

Implementations

impl ConsumerProtocolSubscriptionV1

pub fn encode(&self) -> Result<Vec<u8>>

pub fn decode(bytes: &[u8]) -> Result<Self>

Trait Implementations

impl Clone for ConsumerProtocolSubscriptionV1

fn clone(&self) -> ConsumerProtocolSubscriptionV1

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerProtocolSubscriptionV1

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

Formats the value using the given formatter.

impl Eq for ConsumerProtocolSubscriptionV1

impl PartialEq for ConsumerProtocolSubscriptionV1

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerProtocolSubscriptionV1