View Source KafkaEx.Protocol.Kayrock.SyncGroup (kafka_ex v1.0.0-rc.1)
This module handles SyncGroup request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.
Supported Versions
- V0: Basic SyncGroup
- Request:
group_id,generation_id,member_id,assignments - Response:
error_code,assignment
- 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: Static membership (KIP-345)
- Request: +
group_instance_id - Response: Same as V1/V2
- Request: +
- V4: Flexible version (KIP-482)
- Request: Compact string encoding, +
tagged_fields - Response: Compact bytes 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.