class Kafka::Protocol::OffsetFetchResponse

def offset_for(topic, partition)
  offset_info = topics.fetch(topic).fetch(partition, nil)
  if offset_info
    Protocol.handle_error(offset_info.error_code)
    offset_info.offset
  else
    -1
  end
end