View Source KafkaEx.Protocol.Kayrock.ListOffsets (kafka_ex v1.0.0-rc.1)

This module handles List Offsets request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.

Supported Versions

  • V0: Uses offsets array in response, max_num_offsets in request
  • V1: Single offset field in response (replaces offsets array)
  • V2: Adds isolation_level in request, throttle_time_ms + timestamp in response
  • V3: Adds current_leader_epoch in request partitions (Kayrock schema same as V2)
  • V4: Request adds current_leader_epoch in partitions; response adds leader_epoch
  • V5: No changes vs V4

All known versions (V0-V5) have explicit defimpl implementations. An Any fallback is retained for forward compatibility with unknown future Kayrock versions.