Package com.linkedin.venice.serialization

Class DefaultSerializer

java.lang.Object
com.linkedin.venice.serialization.DefaultSerializer
All Implemented Interfaces:
VeniceKafkaSerializer<byte[]>, Closeable, AutoCloseable
public class DefaultSerializer extends Object implements VeniceKafkaSerializer<byte[]>
Default Kafka VeniceKafkaSerializer

  • Constructor Details

    • DefaultSerializer

      public DefaultSerializer()

  • Method Details

    • close

      public void close()
      Description copied from interface: VeniceKafkaSerializer
      Close this serializer. This method has to be idempotent if the serializer is used in KafkaProducer because it might be called multiple times.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface VeniceKafkaSerializer<byte[]>

    • configure

      public void configure(Map<String,?> configMap, boolean isKey)
      Description copied from interface: VeniceKafkaSerializer
      Configure this class.
      Specified by:
      configure in interface VeniceKafkaSerializer<byte[]>
      Parameters:
      configMap - configs in key/value pairs
      isKey - whether is for key or value

    • serialize

      public byte[] serialize(String topic, byte[] bytes)
      Description copied from interface: VeniceKafkaSerializer
      Construct an array of bytes from the given object
      Specified by:
      serialize in interface VeniceKafkaSerializer<byte[]>
      Parameters:
      topic - Topic to which the object belongs.
      bytes - The object
      Returns:
      The bytes taken from the object

    • deserialize

      public byte[] deserialize(String topic, byte[] bytes)
      Description copied from interface: VeniceKafkaSerializer
      Create an object from an array of bytes
      Specified by:
      deserialize in interface VeniceKafkaSerializer<byte[]>
      Parameters:
      topic - Topic to which the array of bytes belongs.
      bytes - An array of bytes with the objects data
      Returns:
      A java object serialzed from the bytes