#[non_exhaustive]pub struct JoinGroupResponse {
pub throttle_time_ms: i32,
pub error_code: i16,
pub generation_id: i32,
pub protocol_type: Option<StrBytes>,
pub protocol_name: Option<StrBytes>,
pub leader: StrBytes,
pub skip_assignment: bool,
pub member_id: StrBytes,
pub members: Vec<JoinGroupResponseMember>,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-9
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.throttle_time_ms: i32
The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
Supported API versions: 2-9
error_code: i16
The error code, or 0 if there was no error.
Supported API versions: 0-9
generation_id: i32
The generation ID of the group.
Supported API versions: 0-9
protocol_type: Option<StrBytes>
The group protocol name.
Supported API versions: 7-9
protocol_name: Option<StrBytes>
The group protocol selected by the coordinator.
Supported API versions: 0-9
leader: StrBytes
The leader of the group.
Supported API versions: 0-9
skip_assignment: bool
True if the leader must skip running the assignment.
Supported API versions: 9
member_id: StrBytes
The member ID assigned by the group coordinator.
Supported API versions: 0-9
members: Vec<JoinGroupResponseMember>
Supported API versions: 0-9
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl JoinGroupResponse
impl JoinGroupResponse
Sourcepub fn with_throttle_time_ms(self, value: i32) -> Self
pub fn with_throttle_time_ms(self, value: i32) -> Self
Sets throttle_time_ms
to the passed value.
The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
Supported API versions: 2-9
Sourcepub fn with_error_code(self, value: i16) -> Self
pub fn with_error_code(self, value: i16) -> Self
Sets error_code
to the passed value.
The error code, or 0 if there was no error.
Supported API versions: 0-9
Sourcepub fn with_generation_id(self, value: i32) -> Self
pub fn with_generation_id(self, value: i32) -> Self
Sets generation_id
to the passed value.
The generation ID of the group.
Supported API versions: 0-9
Sourcepub fn with_protocol_type(self, value: Option<StrBytes>) -> Self
pub fn with_protocol_type(self, value: Option<StrBytes>) -> Self
Sets protocol_type
to the passed value.
The group protocol name.
Supported API versions: 7-9
Sourcepub fn with_protocol_name(self, value: Option<StrBytes>) -> Self
pub fn with_protocol_name(self, value: Option<StrBytes>) -> Self
Sets protocol_name
to the passed value.
The group protocol selected by the coordinator.
Supported API versions: 0-9
Sourcepub fn with_leader(self, value: StrBytes) -> Self
pub fn with_leader(self, value: StrBytes) -> Self
Sets leader
to the passed value.
The leader of the group.
Supported API versions: 0-9
Sourcepub fn with_skip_assignment(self, value: bool) -> Self
pub fn with_skip_assignment(self, value: bool) -> Self
Sets skip_assignment
to the passed value.
True if the leader must skip running the assignment.
Supported API versions: 9
Sourcepub fn with_member_id(self, value: StrBytes) -> Self
pub fn with_member_id(self, value: StrBytes) -> Self
Sets member_id
to the passed value.
The member ID assigned by the group coordinator.
Supported API versions: 0-9
Sourcepub fn with_members(self, value: Vec<JoinGroupResponseMember>) -> Self
pub fn with_members(self, value: Vec<JoinGroupResponseMember>) -> Self
Sets members
to the passed value.
Supported API versions: 0-9
Sourcepub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
Sets unknown_tagged_fields to the passed value.
Sourcepub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
Inserts an entry into unknown_tagged_fields.
Trait Implementations§
Source§impl Clone for JoinGroupResponse
impl Clone for JoinGroupResponse
Source§fn clone(&self) -> JoinGroupResponse
fn clone(&self) -> JoinGroupResponse
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for JoinGroupResponse
impl Debug for JoinGroupResponse
Source§impl Decodable for JoinGroupResponse
Available on crate feature client
only.
impl Decodable for JoinGroupResponse
client
only.Source§impl Default for JoinGroupResponse
impl Default for JoinGroupResponse
Source§impl Encodable for JoinGroupResponse
Available on crate feature broker
only.
impl Encodable for JoinGroupResponse
broker
only.Source§impl From<JoinGroupResponse> for ResponseKind
Available on crate feature messages_enums
only.
impl From<JoinGroupResponse> for ResponseKind
messages_enums
only.