Package com.linkedin.venice.serialization

Class StringSerializer

java.lang.Object
com.linkedin.venice.serialization.StringSerializer
All Implemented Interfaces:
VeniceKafkaSerializer<String>, Closeable, AutoCloseable
public class StringSerializer extends Object implements VeniceKafkaSerializer<String>

  • Constructor Details

    • StringSerializer

      public StringSerializer()

  • Method Details

    • deserialize

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

    • close

      public void close()
      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<String>

    • configure

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

    • serialize

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