Method: Kafka::FFI::Message#latency

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

#latency ⇒ Integer?

Retrieve the latency since the Message was published to Kafka.

Returns:

  • (Integer) —

    Latency since produce() call in microseconds

  • (nil) —

    Latency not available



191
192
193
194
 
# File 'lib/kafka/ffi/message.rb', line 191

def latency
  latency = ::Kafka::FFI.rd_kafka_message_latency(self)
  latency == -1 ? nil : latency
end