Package org.apache.kafka.common.serialization

Class UUIDSerializer

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, Serializer<java.util.UUID>
    public class UUIDSerializer
extends java.lang.Object
implements Serializer<java.util.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 Summary

      Constructors 
      Constructor Description
      UUIDSerializer()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      Close this serializer.
      void configure​(java.util.Map<java.lang.String,​?> configs, boolean isKey)
      Configure this class.
      byte[] serialize​(java.lang.String topic, java.util.UUID data)
      Convert data into a byte array.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • UUIDSerializer

        public UUIDSerializer()

    • Method Detail

      • configure

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

      • serialize

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

      • close

        public void close()
        Description copied from interface: Serializer
        Close this serializer. This method must be idempotent as it may be called multiple times.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface Serializer<java.util.UUID>