class Kafka::Protocol::OffsetFetchResponse

def self.decode(decoder)
  topics = decoder.array {
    topic = decoder.string
    partitions = decoder.array {
      partition = decoder.int32
      info = PartitionOffsetInfo.new(
        offset: decoder.int64,
        metadata: decoder.string,
        error_code: decoder.int16,
      )
      [partition, info]
    }
    [topic, Hash[partitions]]
  }
  new(topics: Hash[topics])
end