Struct ConsumerProtocolSubscription 

pub struct ConsumerProtocolSubscription {
    pub topics: Vec<String>,
    pub owned_partitions: Vec<(String, i32)>,
    pub generation_id: i32,
    pub rack_id: Option<String>,
}

Java ConsumerPartitionAssignor.Subscription / ConsumerProtocolSubscription (classic JoinGroup member metadata).

ConsumerProtocol::serialize_subscription is Java ConsumerProtocol.serializeSubscription. std::fmt::Display is Java Subscription.toString (groupInstanceId is always null; this type does not store it. User data is omitted when null).

Fields

topics: Vec<String>

Subscribed topic names (Java Subscription.topics).

owned_partitions: Vec<(String, i32)>

Currently owned topic-partitions (Java Subscription.ownedPartitions; v1+).

generation_id: i32

Member generation (Java Subscription.generationId; v2+). Self::DEFAULT_GENERATION when unknown.

rack_id: Option<String>

client.rack (Java Subscription.rackId; v3+).

Implementations

impl ConsumerProtocolSubscription

pub const DEFAULT_GENERATION: i32 = -1

Java AbstractStickyAssignor.DEFAULT_GENERATION (Subscription generationId when unknown).

pub fn new(topics: Vec<String>) -> Self

Java Subscription(List) (no owned partitions, default generation, no rack).

pub fn topics(&self) -> &[String]

Java Subscription.topics.

pub fn owned_partitions(&self) -> &[(String, i32)]

Java Subscription.ownedPartitions.

pub fn generation_id(&self) -> Option<i32>

Java Subscription.generationId (None when the stored value is negative).

pub fn rack_id(&self) -> Option<&str>

Java Subscription.rackId.

Trait Implementations

impl Clone for ConsumerProtocolSubscription

fn clone(&self) -> ConsumerProtocolSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerProtocolSubscription

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

Formats the value using the given formatter.

impl Default for ConsumerProtocolSubscription

fn default() -> Self

Returns the “default value” for a type.

impl Display for ConsumerProtocolSubscription

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

Formats the value using the given formatter.

impl Eq for ConsumerProtocolSubscription

impl PartialEq for ConsumerProtocolSubscription

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerProtocolSubscription