class Kafka::FetchedMessage

def create_time

Returns:
  • (Time) - the timestamp of the message. 
def create_time
  @message.create_time
end

def initialize(message:, topic:, partition:) 

def initialize(message:, topic:, partition:)
  @message = message
  @topic = topic
  @partition = partition
end

def key

Returns:
  • (String) - the key of the message. 
def key
  @message.key
end

def offset

Returns:
  • (Integer) - the offset of the message in the partition. 
def offset
  @message.offset
end

def value

Returns:
  • (String) - the value of the message. 
def value
  @message.value
end