KafkaValueSerializer (venice API)

java.lang.Object
- com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<KafkaMessageEnvelope>
- - com.linkedin.venice.serialization.avro.KafkaValueSerializer

All Implemented Interfaces:

VeniceKafkaSerializer<KafkaMessageEnvelope>, java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Deserializer<KafkaMessageEnvelope>, org.apache.kafka.common.serialization.Serializer<KafkaMessageEnvelope>

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(java.util.function.BiConsumer<java.lang.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
  - Methods inherited from interface org.apache.kafka.common.serialization.Deserializer
    deserialize
  - Methods inherited from interface org.apache.kafka.common.serialization.Serializer
    serialize

Constructor Detail

KafkaValueSerializer
```
public KafkaValueSerializer()
```

KafkaValueSerializer

public KafkaValueSerializer(java.util.function.BiConsumer<java.lang.Integer,org.apache.avro.Schema> newSchemaEncountered)