View Source KafkaEx.Protocol.Kayrock.LeaveGroup (kafka_ex v1.0.0-rc.1)
This module handles LeaveGroup request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.
Supported Versions
- V0: Basic LeaveGroup
- Request:
group_id,member_id - Response:
error_code
- Request:
- V1: Adds throttle_time_ms to response
- Request: Same as V0
- Response: +
throttle_time_ms
- V2: No changes vs V1 (pure version bump)
- V3: Batch leave (KIP-345) -- STRUCTURAL CHANGE
- Request: -
member_id, +membersarray (each withmember_id,group_instance_id) - Response: +
membersarray with per-membererror_code
- Request: -
- V4: Flexible version (KIP-482)
- Request: Compact string encoding, +
tagged_fields - Response: Compact encoding, +
tagged_fields - Domain-relevant fields identical to V3
- Request: Compact string encoding, +
All known versions (V0-V4) have explicit defimpl implementations.
An Any fallback is retained for forward compatibility with unknown
future Kayrock versions.