class Kafka::Protocol::DescribeConfigsRequest
Public Class Methods
new(resources:)
click to toggle source
# File lib/kafka/protocol/describe_configs_request.rb, line 7 def initialize(resources:) @resources = resources end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/describe_configs_request.rb, line 11 def api_key DESCRIBE_CONFIGS_API end
api_version()
click to toggle source
# File lib/kafka/protocol/describe_configs_request.rb, line 15 def api_version 0 end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/describe_configs_request.rb, line 23 def encode(encoder) encoder.write_array(@resources) do |type, name, configs| encoder.write_int8(type) encoder.write_string(name) encoder.write_array(configs) do |config| encoder.write_string(config) end end end
response_class()
click to toggle source
# File lib/kafka/protocol/describe_configs_request.rb, line 19 def response_class Protocol::DescribeConfigsResponse end