Sha256: 6b388ecfe71176964d3167b4c60f49a125eef19ec190636cb9428644e16957de
Contents?: true
Size: 818 Bytes
Versions: 10
Compression:
Stored size: 818 Bytes
Contents
# frozen_string_literal: true
module Kafka
class FetchedMessage
# @return [String] the name of the topic that the message was written to.
attr_reader :topic
# @return [Integer] the partition number that the message was written to.
attr_reader :partition
def initialize(message:, topic:, partition:)
@message = message
@topic = topic
@partition = partition
end
# @return [String] the value of the message.
def value
@message.value
end
# @return [String] the key of the message.
def key
@message.key
end
# @return [Integer] the offset of the message in the partition.
def offset
@message.offset
end
# @return [Time] the timestamp of the message.
def create_time
@message.create_time
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems