class Kafka::Protocol::ConsumerGroupProtocol

Public Class Methods

new(version: 0, topics:, user_data: nil) click to toggle source
# File lib/kafka/protocol/consumer_group_protocol.rb, line 6
def initialize(version: 0, topics:, user_data: nil)
  @version = version
  @topics = topics
  @user_data = user_data
end

Public Instance Methods

encode(encoder) click to toggle source
# File lib/kafka/protocol/consumer_group_protocol.rb, line 12
def encode(encoder)
  encoder.write_int16(@version)
  encoder.write_array(@topics) {|topic| encoder.write_string(topic) }
  encoder.write_bytes(@user_data)
end