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