Contents

module Rdkafka
  class RdkafkaError < RuntimeError
    attr_reader :rdkafka_response

    def initialize(response)
      @rdkafka_response = response
    end

    def code
      if @rdkafka_response.nil?
        :unknown_error
      else
        Rdkafka::FFI.rd_kafka_err2name(@rdkafka_response).downcase.to_sym
      end
    end

    def to_s
      if @rdkafka_response.nil?
        "Unknown error: Response code is nil"
      else
        Rdkafka::FFI.rd_kafka_err2str(@rdkafka_response)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rdkafka-0.0.1	lib/rdkafka/error.rb