Package com.linkedin.davinci.validation
package com.linkedin.davinci.validation
-
ClassDescriptionWrapper class for
PartitionTracker
with latestConsumedRtOffset (LCRO) for the ConsumptionTask to enqueue to the Drainer.This class is a library that can validate the Kafka message during consumption, which can be used in Venice-Server/Da-Vinci and ETL.This class maintains state about all the upstream producers for a given partition.