Package com.linkedin.venice.serialization.avro
package com.linkedin.venice.serialization.avro
-
ClassDescriptionThis enum lays out the basic specs of the various stateful protocols used in Venice.AvroSpecificStoreDeserializerCache<V extends org.apache.avro.specific.SpecificRecord>InternalAvroSpecificSerializer<SPECIFIC_RECORD extends org.apache.avro.specific.SpecificRecord>Serializer for translating a versioned protocol of Avro records.Serializer for the Avro-based kafka protocol defined in:
KafkaMessageEnvelopeThis class needs to be defined explicitly, rather than just instantiating aInternalAvroSpecificSerializerbecause it is used as a config passed to the Kafka producer.This class is to reuse the original array for put payload of each message to reduce the unnecessary byte array allocation.This class helps checks presence of a schema version in ZK.This class is a thin wrapper ofAvroSerializerandAvroGenericDeserializer.