View Source KafkaEx.Protocol.Kayrock.JoinGroup (kafka_ex v1.0.0-rc.1)
This module handles JoinGroup request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.
Supported Versions
- V0: Basic JoinGroup with session_timeout
- Request:
group_id,session_timeout_ms,member_id,protocol_type,protocols - Response:
error_code,generation_id,protocol_name,leader,member_id,members
- Request:
- V1: Adds rebalance_timeout
- Request: +
rebalance_timeout_ms - Response: Same as V0
- Request: +
- V2: Adds throttle_time_ms to response
- Request: Same as V1
- Response: +
throttle_time_ms
- V3: No changes vs V2 (pure version bump)
- V4: No changes vs V3 (pure version bump)
- V5: Static membership (KIP-345)
- Request: +
group_instance_id - Response: +
group_instance_idper member (not extracted to domain layer)
- Request: +
- V6: Flexible version (KIP-482)
- Request: Compact string encoding, +
tagged_fields - Response: Compact string encoding, +
tagged_fields - Domain-relevant fields identical to V5
- Request: Compact string encoding, +
All known versions (V0-V6) have explicit defimpl implementations.
An Any fallback is retained for forward compatibility with unknown
future Kayrock versions.