Struct ConsumerGroupDescription 

pub struct ConsumerGroupDescription { /* private fields */ }

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

Corresponds to org.apache.kafka.clients.admin.ConsumerGroupDescription.

Note: Java’s @Deprecated(forRemoval = true) constructors that accept a ConsumerGroupState, and the deprecated state() accessor, are not translated; use new and group_state.

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.

Mirrors the primary ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, GroupType, GroupState, Node, Set<AclOperation>, Optional<Integer>, Optional<Integer>) constructor. coordinator is None when the coordinator is not known (Java’s nullable Node).

pub fn group_id(&self) -> &str

The id of the consumer group. Mirrors groupId().

pub fn is_simple_consumer_group(&self) -> bool

Whether the consumer group is simple. Mirrors isSimpleConsumerGroup().

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

The members of the consumer group. Mirrors members().

pub fn partition_assignor(&self) -> &str

The consumer group partition assignor. Mirrors partitionAssignor().

pub fn group_type(&self) -> GroupType

The group type. Mirrors type().

pub fn group_state(&self) -> GroupState

The group state. Mirrors groupState().

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

The consumer group coordinator, or None if not known. Mirrors coordinator().

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

The authorized operations for this group, or None if the broker did not report them (Java returns null). Mirrors authorizedOperations().

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

The epoch of the consumer group. Mirrors groupEpoch().

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

The epoch of the target assignment. Mirrors targetAssignmentEpoch().

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 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