Sha256: 297a9e034f975035c3f5bbcc707235791b801a27a9fcfe92f855ed9c4707605d
Contents?: true
Size: 1.04 KB
Versions: 18
Compression:
Stored size: 1.04 KB
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
# @return [Hash<String, String>] the headers of the message.
def headers
@message.headers
end
# @return [Boolean] whether this record is a control record
def is_control_record
@message.is_control_record
end
end
end
Version data entries
18 entries across 18 versions & 3 rubygems