class Kafka::Protocol::AlterConfigsRequest

Public Class Methods

new(resources:) click to toggle source
# File lib/kafka/protocol/alter_configs_request.rb, line 7
def initialize(resources:)
  @resources = resources
end

Public Instance Methods

api_key() click to toggle source
# File lib/kafka/protocol/alter_configs_request.rb, line 11
def api_key
  ALTER_CONFIGS_API
end
api_version() click to toggle source
# File lib/kafka/protocol/alter_configs_request.rb, line 15
def api_version
  0
end
encode(encoder) click to toggle source
# File lib/kafka/protocol/alter_configs_request.rb, line 23
def encode(encoder)
  encoder.write_array(@resources) do |type, name, configs|
    encoder.write_int8(type)
    encoder.write_string(name)

    configs = configs.to_a
    encoder.write_array(configs) do |config_name, config_value|
      # Config value is nullable. In other cases, we must write the
      # stringified value.
      config_value = config_value.to_s unless config_value.nil?

      encoder.write_string(config_name)
      encoder.write_string(config_value)
    end
  end
  # validate_only. We'll skip this feature.
  encoder.write_boolean(false)
end
response_class() click to toggle source
# File lib/kafka/protocol/alter_configs_request.rb, line 19
def response_class
  Protocol::AlterConfigsResponse
end