Class StringDeserializer

All Implemented Interfaces:
Closeable, AutoCloseable, Deserializer<String>

public class StringDeserializer extends Object implements Deserializer<String>
String encoding defaults to UTF8 and can be customized by setting the property key.deserializer.encoding, value.deserializer.encoding or deserializer.encoding. The first two take precedence over the last.
  • Constructor Details

    • StringDeserializer

      public StringDeserializer()
  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Description copied from interface: Deserializer
      Configure this class.
      Specified by:
      configure in interface Deserializer<String>
      configs - configs in key/value pairs
      isKey - whether is for key or value
    • deserialize

      public String deserialize(String topic, byte[] data)
      Description copied from interface: Deserializer
      Deserialize a record value from a byte array into a value or object.
      Specified by:
      deserialize in interface Deserializer<String>
      topic - topic associated with the data
      data - serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.
      deserialized typed data; may be null