class Kafka::Protocol::AlterConfigsResponse

Attributes

resources[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/alter_configs_response.rb, line 24
def self.decode(decoder)
  throttle_time_ms = decoder.int32
  resources = decoder.array do
    error_code = decoder.int16
    error_message = decoder.string

    resource_type = decoder.int8
    if Kafka::Protocol::RESOURCE_TYPES[resource_type].nil?
      raise Kafka::ProtocolError, "Resource type not supported: #{resource_type}"
    end
    resource_name = decoder.string

    ResourceDescription.new(
      type: RESOURCE_TYPES[resource_type],
      name: resource_name,
      error_code: error_code,
      error_message: error_message
    )
  end

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