class Kafka::Protocol::MetadataRequest

def api_key 

def api_key
  TOPIC_METADATA_API
end

def api_version 

def api_version
  1
end

def encode(encoder) 

def encode(encoder)
  encoder.write_array(@topics) {|topic| encoder.write_string(topic) }
end

def initialize(topics: [])

Parameters:
  • topics (Array) -- 
def initialize(topics: [])
  @topics = topics
end

def response_class 

def response_class
  Protocol::MetadataResponse
end