Package org.apache.kafka.common.serialization

Class StringSerializer

java.lang.Object
org.apache.kafka.common.serialization.StringSerializer
All Implemented Interfaces:
Closeable, AutoCloseable, Serializer<String>
public class StringSerializerextends Object implements Serializer<String>
String encoding defaults to UTF8 and can be customized by setting the property key.serializer.encoding, value.serializer.encoding or serializer.encoding. The first two take precedence over the last.

  • Constructor Details

    • StringSerializer

      public StringSerializer()

  • Method Details

    • configure

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

    • serialize

      public byte[] serialize(String topic, String data)
      Description copied from interface: Serializer
      Convert data into a byte array.
      Specified by:
      serialize in interface Serializer<String>
      Parameters:
      topic - topic associated with data
      data - typed data
      Returns:
      serialized bytes