Sha256: 65021e045bcda6a52eb52be23eafee651a78cb702a84c3f83ac8b567ab6cdfff
Contents?: true
Size: 544 Bytes
Versions: 49
Compression:
Stored size: 544 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class MetadataRequest
# A request for cluster metadata.
#
# @param topics [Array<String>]
def initialize(topics: [])
@topics = topics
end
def api_key
TOPIC_METADATA_API
end
def api_version
1
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
49 entries across 49 versions & 4 rubygems