Sha256: c13f289381f59f125323cb9f56cc03ced042603804e3246208c869941f141c30
Contents?: true
Size: 946 Bytes
Versions: 56
Compression:
Stored size: 946 Bytes
Contents
module Kafka
module Protocol
class MemberAssignment
attr_reader :topics
def initialize(version: 0, topics: {}, user_data: nil)
@version = version
@topics = topics
@user_data = user_data
end
def assign(topic, partitions)
@topics[topic] ||= []
@topics[topic].concat(partitions)
end
def encode(encoder)
encoder.write_int16(@version)
encoder.write_array(@topics) do |topic, partitions|
encoder.write_string(topic)
encoder.write_array(partitions) do |partition|
encoder.write_int32(partition)
end
end
encoder.write_bytes(@user_data)
end
def self.decode(decoder)
new(
version: decoder.int16,
topics: Hash[decoder.array { [decoder.string, decoder.array { decoder.int32 }] }],
user_data: decoder.bytes,
)
end
end
end
end
Version data entries
56 entries across 56 versions & 1 rubygems