View Source KafkaEx.Protocol.Kayrock.LeaveGroup.RequestHelpers (kafka_ex v1.0.0-rc.1)
Shared helper functions for building LeaveGroup requests across all versions.
Version differences:
- V0-V2:
group_id,member_id(all schema-identical) - V3-V4: STRUCTURAL CHANGE (KIP-345 batch leave) -- replaces
member_idwithmembersarray. Each member hasmember_idandgroup_instance_id. - V4: Flexible version (KIP-482) with compact encoding -- Kayrock handles encoding
Summary
Functions
Builds a LeaveGroup V0-V2 request by populating the request template with extracted fields. This is shared logic between V0-V2 requests as they have identical structure.
Builds a LeaveGroup V3+ request (KIP-345 batch leave).
Extracts common fields from request options (V0-V2).
Functions
Builds a LeaveGroup V0-V2 request by populating the request template with extracted fields. This is shared logic between V0-V2 requests as they have identical structure.
Builds a LeaveGroup V3+ request (KIP-345 batch leave).
V3 introduces a structural change: the single member_id field is replaced
with a members array. Each member in the array has:
member_id(required)group_instance_id(optional, for static membership)
V4 is the flexible version (KIP-482) with the same logical fields -- Kayrock handles compact encoding.
Options
group_id(required): The consumer group IDmembers(required): List of member maps, each with:member_idand optionally:group_instance_id
Extracts common fields from request options (V0-V2).