Class UUIDSerializer

java.lang.Object
org.apache.kafka.common.serialization.UUIDSerializer
All Implemented Interfaces:
Closeable, AutoCloseable, Serializer<UUID>

public class UUIDSerializer
extends Object
implements Serializer<UUID>
We are converting UUID to String before serializing. 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

    • UUIDSerializer

      public UUIDSerializer()
  • 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<UUID>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value
    • serialize

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