class Kafka::Protocol::JoinGroupRequest
def encode(encoder)
def encode(encoder) encoder.write_string(@group_id) encoder.write_int32(@session_timeout) encoder.write_string(@member_id) encoder.write_string(@protocol_type) encoder.write_array(@group_protocols) do |name, metadata| encoder.write_string(name) encoder.write_bytes(Encoder.encode_with(metadata)) end end