Method: Kafka::FFI::Message#offset

Defined in:

lib/kafka/ffi/message.rb

#offset ⇒ Integer, RD_KAFKA_OFFSET_INVALID

Returns the message’s offset as published in the topic’s partition. When error != nil, offset the error occurred at.

Returns:

• (Integer) —

  Message offset

• (RD_KAFKA_OFFSET_INVALID) —

  Message was retried and idempotence is enabled.

# File 'lib/kafka/ffi/message.rb', line 71

def offset
  self[:offset]
end