class Kafka::Protocol::MetadataRequest

Public Class Methods

new(topics: []) click to toggle source

A request for cluster metadata.

@param topics [Array<String>]

# File lib/kafka/protocol/metadata_request.rb, line 10
def initialize(topics: [])
  @topics = topics
end

Public Instance Methods

api_key() click to toggle source
# File lib/kafka/protocol/metadata_request.rb, line 14
def api_key
  TOPIC_METADATA_API
end
api_version() click to toggle source
# File lib/kafka/protocol/metadata_request.rb, line 18
def api_version
  1
end
encode(encoder) click to toggle source
# File lib/kafka/protocol/metadata_request.rb, line 26
def encode(encoder)
  encoder.write_array(@topics) {|topic| encoder.write_string(topic) }
end
response_class() click to toggle source
# File lib/kafka/protocol/metadata_request.rb, line 22
def response_class
  Protocol::MetadataResponse
end