Package com.linkedin.venice.kafka.protocol.state
package com.linkedin.venice.kafka.protocol.state
-
ClassesClassDescriptionGlobal Realtime Topic Data Integrity Validator is the RT DIV snapshot propagated from the leader to the followers via local VTA record containing the incremental push replica status, including timestamp and status.This record holds the state necessary for a consumer to checkpoint its progress when consuming a Venice partition.A record containing the state pertaining to the data sent by one upstream producer into one partition.This record maintains store-version level state, such as the StartOfBufferReplay Control Message, in the case of Hybrid Stores.