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_epoch per 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.