Exception: Rdkafka::RdkafkaError
- Inherits:
-
RuntimeError
- Object
- RuntimeError
- Rdkafka::RdkafkaError
- Defined in:
- lib/rdkafka/error.rb
Overview
Error returned by the underlying rdkafka library.
Direct Known Subclasses
Instance Attribute Summary collapse
-
#message_prefix ⇒ Integer
readonly
The underlying raw error response.
-
#rdkafka_response ⇒ Integer
readonly
The underlying raw error response.
Instance Method Summary collapse
-
#code ⇒ Symbol
This error's code, for example
:partition_eof
,:msg_size_too_large
. -
#is_partition_eof? ⇒ Boolean
Whether this error indicates the partition is EOF.
-
#to_s ⇒ String
Human readable representation of this error.
Instance Attribute Details
#message_prefix ⇒ Integer (readonly)
The underlying raw error response
6 7 8 |
# File 'lib/rdkafka/error.rb', line 6 def @message_prefix end |
#rdkafka_response ⇒ Integer (readonly)
The underlying raw error response
6 7 8 |
# File 'lib/rdkafka/error.rb', line 6 def rdkafka_response @rdkafka_response end |
Instance Method Details
#code ⇒ Symbol
This error's code, for example :partition_eof
, :msg_size_too_large
.
17 18 19 20 21 22 23 24 |
# File 'lib/rdkafka/error.rb', line 17 def code code = Rdkafka::Bindings.rd_kafka_err2name(@rdkafka_response).downcase if code[0] == "_" code[1..-1].to_sym else code.to_sym end end |
#is_partition_eof? ⇒ Boolean
Whether this error indicates the partition is EOF.
39 40 41 |
# File 'lib/rdkafka/error.rb', line 39 def is_partition_eof? code == :partition_eof end |
#to_s ⇒ String
Human readable representation of this error.
28 29 30 31 32 33 34 35 |
# File 'lib/rdkafka/error.rb', line 28 def to_s = if "#{} - " else '' end "#{}#{Rdkafka::Bindings.rd_kafka_err2str(@rdkafka_response)} (#{code})" end |