class Kafka::Protocol::ApiVersionsResponse

Attributes

apis[R]
error_code[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/api_versions_response.rb, line 38
def self.decode(decoder)
  error_code = decoder.int16

  apis = decoder.array do
    ApiInfo.new(
      api_key: decoder.int16,
      min_version: decoder.int16,
      max_version: decoder.int16,
    )
  end

  new(error_code: error_code, apis: apis)
end
new(error_code:, apis:) click to toggle source
# File lib/kafka/protocol/api_versions_response.rb, line 33
def initialize(error_code:, apis:)
  @error_code = error_code
  @apis = apis
end