pub struct ModernConsumerGroupDescription { /* private fields */ }Expand description
Description returned by Kafka’s modern ConsumerGroupDescribe API.
Implementations§
Source§impl ModernConsumerGroupDescription
impl ModernConsumerGroupDescription
Sourcepub fn group_epoch(&self) -> i32
pub fn group_epoch(&self) -> i32
Returns the group’s current epoch.
Sourcepub fn assignment_epoch(&self) -> i32
pub fn assignment_epoch(&self) -> i32
Returns the group’s target assignment epoch.
Sourcepub fn assignor_name(&self) -> &str
pub fn assignor_name(&self) -> &str
Returns the selected server-side assignor.
Sourcepub fn members(&self) -> &[ModernConsumerGroupMember]
pub fn members(&self) -> &[ModernConsumerGroupMember]
Returns current members in broker response order.
Returns Kafka’s authorized-operations bitfield, or its sentinel value when the request did not ask for authorization details.
Sourcepub fn is_success(&self) -> bool
pub fn is_success(&self) -> bool
Returns whether Kafka described this group successfully.
Sourcepub fn error_code(&self) -> i16
pub fn error_code(&self) -> i16
Returns Kafka’s raw group error code.
Sourcepub fn error_message(&self) -> Option<&str>
pub fn error_message(&self) -> Option<&str>
Returns Kafka’s optional group error message.
Sourcepub fn throttle_time(&self) -> Duration
pub fn throttle_time(&self) -> Duration
Returns the coordinator’s throttle time for this request.
Trait Implementations§
Source§impl Clone for ModernConsumerGroupDescription
impl Clone for ModernConsumerGroupDescription
Source§fn clone(&self) -> ModernConsumerGroupDescription
fn clone(&self) -> ModernConsumerGroupDescription
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Eq for ModernConsumerGroupDescription
impl StructuralPartialEq for ModernConsumerGroupDescription
Auto Trait Implementations§
impl Freeze for ModernConsumerGroupDescription
impl RefUnwindSafe for ModernConsumerGroupDescription
impl Send for ModernConsumerGroupDescription
impl Sync for ModernConsumerGroupDescription
impl Unpin for ModernConsumerGroupDescription
impl UnsafeUnpin for ModernConsumerGroupDescription
impl UnwindSafe for ModernConsumerGroupDescription
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more