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