Sha256: 8d6bf0262c85f2a2848b043251a0ab74446af0fd3c44382656847cd5f47c9561
Contents?: true
Size: 787 Bytes
Versions: 9
Compression:
Stored size: 787 Bytes
Contents
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
9 entries across 9 versions & 1 rubygems