module Kafka::Protocol

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