Sha256: 6d60ab93963216b40805946ac14af0f0f51635d9e3a484118a57d79872e03952
Contents?: true
Size: 729 Bytes
Versions: 23
Compression:
Stored size: 729 Bytes
Contents
module Kafka
class PendingMessage
attr_reader :value, :key, :topic, :partition, :partition_key, :create_time, :bytesize
def initialize(value, key, topic, partition, partition_key, create_time)
@value = value
@key = key
@topic = topic
@partition = partition
@partition_key = partition_key
@create_time = create_time
@bytesize = key.to_s.bytesize + value.to_s.bytesize
end
def ==(other)
@value == other.value &&
@key == other.key &&
@topic == other.topic &&
@partition == other.partition &&
@partition_key == other.partition_key &&
@create_time == other.create_time &&
@bytesize == other.bytesize
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems