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