View Source KafkaEx.Protocol.Kayrock.OffsetFetch (kafka_ex v1.0.0-rc.1)
This module handles Offset Fetch request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.
Supported Versions
- V0: Basic fetch from Zookeeper
- V1: Coordinator-based fetch from Kafka (recommended)
- V2: Enhanced error handling (adds top-level error_code)
- V3: Includes throttle time
- V4: No changes vs V3 (pure version bump)
- V5: Response adds
committed_leader_epochper partition - V6: Flexible version (KIP-482) -- compact encodings + tagged fields
All known versions (V0-V6) have explicit defimpl implementations.
An Any fallback is retained for forward compatibility with unknown
future Kayrock versions.