Sha256: f7dd4ebcf2fe276069e3b5baa6f9c4a4e249592d4b6ff75a060f073d1dacd218
Contents?: true
Size: 811 Bytes
Versions: 9
Compression:
Stored size: 811 Bytes
Contents
module Kafka
class FetchedMessage
# @return [String] the value of the message.
attr_reader :value
# @return [String] the key of the message.
attr_reader :key
# @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
# @return [Integer] the offset of the message in the partition.
attr_reader :offset
# @return [Time] the timestamp of the message.
attr_reader :create_time
def initialize(value: nil, key: nil, topic:, partition:, offset:, create_time: nil)
@value = value
@key = key
@topic = topic
@partition = partition
@offset = offset
@create_time = create_time
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems