Sha256: d7e3ebe35876dd7e62ef2d86007525746fc1f596c1acb3e5eadcb1fb5b41bfec
Contents?: true
Size: 558 Bytes
Versions: 49
Compression:
Stored size: 558 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class OffsetCommitResponse
attr_reader :topics
def initialize(topics:)
@topics = topics
end
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
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems