Sha256: d45ba1cdf452f7a35ad1017cffad9a29276ce0cf1999ea9f6648be45b6c32a11
Contents?: true
Size: 671 Bytes
Versions: 39
Compression:
Stored size: 671 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
def initialize(value:, key:, topic:, partition:, offset:)
@value = value
@key = key
@topic = topic
@partition = partition
@offset = offset
end
end
end
Version data entries
39 entries across 39 versions & 1 rubygems