#[non_exhaustive]pub struct JoinGroupRequest {
pub group_id: GroupId,
pub session_timeout_ms: i32,
pub rebalance_timeout_ms: i32,
pub member_id: StrBytes,
pub group_instance_id: Option<StrBytes>,
pub protocol_type: StrBytes,
pub protocols: IndexMap<StrBytes, JoinGroupRequestProtocol>,
pub reason: Option<StrBytes>,
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.group_id: GroupId
The group identifier.
Supported API versions: 0-9
session_timeout_ms: i32
The coordinator considers the consumer dead if it receives no heartbeat after this timeout in milliseconds.
Supported API versions: 0-9
rebalance_timeout_ms: i32
The maximum time in milliseconds that the coordinator will wait for each member to rejoin when rebalancing the group.
Supported API versions: 1-9
member_id: StrBytes
The member id assigned by the group coordinator.
Supported API versions: 0-9
group_instance_id: Option<StrBytes>
The unique identifier of the consumer instance provided by end user.
Supported API versions: 5-9
protocol_type: StrBytes
The unique name the for class of protocols implemented by the group we want to join.
Supported API versions: 0-9
protocols: IndexMap<StrBytes, JoinGroupRequestProtocol>
The list of protocols that the member supports.
Supported API versions: 0-9
reason: Option<StrBytes>
The reason why the member (re-)joins the group.
Supported API versions: 8-9
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Trait Implementations§
source§impl Builder for JoinGroupRequest
impl Builder for JoinGroupRequest
§type Builder = JoinGroupRequestBuilder
type Builder = JoinGroupRequestBuilder
derive_builder::Builder
type for this protocol item.source§impl Clone for JoinGroupRequest
impl Clone for JoinGroupRequest
source§fn clone(&self) -> JoinGroupRequest
fn clone(&self) -> JoinGroupRequest
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for JoinGroupRequest
impl Debug for JoinGroupRequest
source§impl Decodable for JoinGroupRequest
impl Decodable for JoinGroupRequest
source§impl Default for JoinGroupRequest
impl Default for JoinGroupRequest
source§impl Encodable for JoinGroupRequest
impl Encodable for JoinGroupRequest
source§fn encode<B: ByteBufMut>(
&self,
buf: &mut B,
version: i16
) -> Result<(), EncodeError>
fn encode<B: ByteBufMut>( &self, buf: &mut B, version: i16 ) -> Result<(), EncodeError>
source§fn compute_size(&self, version: i16) -> Result<usize, EncodeError>
fn compute_size(&self, version: i16) -> Result<usize, EncodeError>
source§impl HeaderVersion for JoinGroupRequest
impl HeaderVersion for JoinGroupRequest
source§fn header_version(version: i16) -> i16
fn header_version(version: i16) -> i16
source§impl Message for JoinGroupRequest
impl Message for JoinGroupRequest
source§const VERSIONS: VersionRange = _
const VERSIONS: VersionRange = _
source§const DEPRECATED_VERSIONS: Option<VersionRange> = _
const DEPRECATED_VERSIONS: Option<VersionRange> = _
source§impl PartialEq for JoinGroupRequest
impl PartialEq for JoinGroupRequest
source§fn eq(&self, other: &JoinGroupRequest) -> bool
fn eq(&self, other: &JoinGroupRequest) -> bool
self
and other
values to be equal, and is used
by ==
.