class Kafka::Protocol::OffsetCommitResponse

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

def initialize(topics:)
  @topics = topics
end