Sha256: 3ba71bfd5522d951709b875d7f48e212ed1286f73d497000b5a5203cc645f3b2
Contents?: true
Size: 1021 Bytes
Versions: 49
Compression:
Stored size: 1021 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class AlterConfigsRequest
def initialize(resources:)
@resources = resources
end
def api_key
ALTER_CONFIGS_API
end
def api_version
0
end
def response_class
Protocol::AlterConfigsResponse
end
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
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems