class Kafka::Protocol::ListOffsetRequest

def encode(encoder)
  encoder.write_int32(@replica_id)
  encoder.write_array(@topics) do |topic, partitions|
    encoder.write_string(topic)
    encoder.write_array(partitions) do |partition|
      encoder.write_int32(partition.fetch(:partition))
      encoder.write_int64(partition.fetch(:time))
      encoder.write_int32(partition.fetch(:max_offsets))
    end
  end
end