Sha256: a86e03eba101531b12c2e25dfa213902399389c2eb51d268418b811a5037483f
Contents?: true
Size: 458 Bytes
Versions: 33
Compression:
Stored size: 458 Bytes
Contents
module Kafka
module Protocol
class TopicMetadataRequest
# A request for cluster metadata.
#
# @param topics [Array<String>]
def initialize(topics: [])
@topics = topics
end
def api_key
3
end
def response_class
Protocol::MetadataResponse
end
def encode(encoder)
encoder.write_array(@topics) {|topic| encoder.write_string(topic) }
end
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems