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