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