Struct ConsumerGroupDescription 

pub struct ConsumerGroupDescription { /* private fields */ }

A detailed description of a single consumer group in the cluster.

Implementations

impl ConsumerGroupDescription

pub fn new( group_id: impl Into<String>, is_simple_consumer_group: bool, members: Vec<MemberDescription>, partition_assignor: impl Into<String>, group_type: GroupType, group_state: GroupState, coordinator: Option<Node>, authorized_operations: Option<BTreeSet<AclOperation>>, group_epoch: Option<i32>, target_assignment_epoch: Option<i32>, ) -> Self

Creates a consumer group description with all fields.

Arguments

• group_id - the id of the consumer group.
• is_simple_consumer_group - whether the group is a simple consumer group.
• members - the members of the group.
• partition_assignor - the name of the partition assignor.
• group_type - the group protocol type.
• group_state - the group state.
• coordinator - the group coordinator, or None if not known.
• authorized_operations - the authorized operations for this group, or None if not known.
• group_epoch - the epoch of the group, or None for a classic group.
• target_assignment_epoch - the epoch of the target assignment, or None for a classic group.

pub fn group_id(&self) -> &str

Returns the id of the consumer group.

pub fn is_simple_consumer_group(&self) -> bool

Returns whether the consumer group is simple.

pub fn members(&self) -> &[MemberDescription]

Returns the members of the consumer group.

pub fn partition_assignor(&self) -> &str

Returns the consumer group partition assignor.

pub fn type(&self) -> GroupType

Returns the group type.

pub fn group_state(&self) -> GroupState

Returns the group state, or GroupState::Unknown if the state is too new for us to parse.

pub fn coordinator(&self) -> Option<&Node>

Returns the consumer group coordinator, or None if not known.

pub fn authorized_operations(&self) -> Option<&BTreeSet<AclOperation>>

Returns the authorized operations for this group, or None if that information is not known.

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

Returns the epoch of the consumer group. The optional is set to an integer if it is a GroupType::Consumer group, and to None if it is a GroupType::Classic group.

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

Returns the epoch of the target assignment. The optional is set to an integer if it is a GroupType::Consumer group, and to None if it is a GroupType::Classic group.

Trait Implementations

impl Clone for ConsumerGroupDescription

fn clone(&self) -> ConsumerGroupDescription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerGroupDescription

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

Formats the value using the given formatter.

impl Display for ConsumerGroupDescription

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

Java’s toString(): an absent coordinator, operation set or epoch prints as null, and the operations as Java’s [A, B].

impl Hash for ConsumerGroupDescription

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ConsumerGroupDescription

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

impl StructuralPartialEq for ConsumerGroupDescription