Method: Kafka::FFI::Message#error

Defined in:
lib/kafka/ffi/message.rb

#error ⇒ nil, Kafka::ResponseError

Retrieve the error associated with this message. For consumers this is used to report per-topic+partition consumer errors. For producers this is set when received in the dr_msg_cb callback to signify a fatal error publishing the message.

Returns:

  • (nil) —

    Message does not have an error

  • (Kafka::ResponseError) —

    RD_KAFKA_RESP_ERR__* error code



26
27
28
29
30
 
# File 'lib/kafka/ffi/message.rb', line 26

def error
  if self[:err] != :ok
    ::Kafka::ResponseError.new(self[:err])
  end
end