Method: Kafka::FFI::Message#timestamp

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

#timestamp ⇒ Integer?

Retrieve the timestamp for a consumed message.

Examples:

Convert timestamp to a Time

ts = message.timestamp
ts = ts && Time.at(0, ts, :millisecond).utc

Returns:

  • (Integer) —

    Message timestamp as milliseconds since unix epoch

  • (nil) —

    Timestamp is not available



181
182
183
184
185
 
# File 'lib/kafka/ffi/message.rb', line 181

def timestamp
  # @todo: Type (second param) [rd_kafka_timestamp_type_t enum]
  ts = ::Kafka::FFI.rd_kafka_message_timestamp(self, nil)
  ts == -1 ? nil : ts
end