Package com.linkedin.venice.serialization.avro

Class KafkaValueSerializer

java.lang.Object

com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<KafkaMessageEnvelope>

com.linkedin.venice.serialization.avro.KafkaValueSerializer

All Implemented Interfaces:

VeniceKafkaSerializer<KafkaMessageEnvelope>, Closeable, AutoCloseable

Direct Known Subclasses:

OptimizedKafkaValueSerializer

public class KafkaValueSerializer
extends InternalAvroSpecificSerializer<KafkaMessageEnvelope>

Serializer for the Avro-based kafka protocol defined in: KafkaMessageEnvelope This class needs to be defined explicitly, rather than just instantiating a InternalAvroSpecificSerializer because it is used as a config passed to the Kafka producer.

Field Summary

Fields inherited from class com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer

MAX_ATTEMPTS_FOR_SCHEMA_READER, SENTINEL_PROTOCOL_VERSION_USED_FOR_UNDETECTABLE_COMPILED_SCHEMA, SENTINEL_PROTOCOL_VERSION_USED_FOR_UNVERSIONED_PROTOCOL, VENICE_SCHEMA_READER_CONFIG, WAIT_TIME_BETWEEN_SCHEMA_READER_ATTEMPTS_IN_MS

Constructor Summary

Constructors

Constructor	Description
KafkaValueSerializer()
KafkaValueSerializer(BiConsumer<Integer,org.apache.avro.Schema> newSchemaEncountered)

Method Summary

Methods inherited from class com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer

close, configure, createBinaryDecoder, deserialize, deserialize, deserialize, deserialize, deserialize, getCompiledProtocol, knownProtocols, removeAllSchemas, serialize, serialize, setSchemaReader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaValueSerializer

public KafkaValueSerializer()

KafkaValueSerializer

public KafkaValueSerializer(BiConsumer<Integer,org.apache.avro.Schema> newSchemaEncountered)