module Kafka::Protocol

def self.api_name(api_key)
  APIS.fetch(api_key, :unknown)
end

def self.handle_error(error_code, error_message = nil)
  if error_code == 0
    # No errors, yay!
  elsif error = ERRORS[error_code]
    raise error, error_message
  else
    raise UnknownError, "Unknown error with code #{error_code} #{error_message}"
  end
end