Sha256: ce9e5ae4977b88ff6b9669625483f50edc1757b5d1fb884e890d6aa3bf66726e
Contents?: true
Size: 454 Bytes
Versions: 49
Compression:
Stored size: 454 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class ConsumerGroupProtocol
def initialize(version: 0, topics:, user_data: nil)
@version = version
@topics = topics
@user_data = user_data
end
def encode(encoder)
encoder.write_int16(@version)
encoder.write_array(@topics) {|topic| encoder.write_string(topic) }
encoder.write_bytes(@user_data)
end
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems