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 Summary
Constructors Constructor Description UUIDSerializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Map<String,?> configs, boolean isKey)
Configure this class.byte[]
serialize(String topic, UUID data)
Convertdata
into a byte array.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.common.serialization.Serializer
close, serialize
-
-
-
-
Method Detail
-
configure
public void configure(Map<String,?> configs, boolean isKey)
Description copied from interface:Serializer
Configure this class.- Specified by:
configure
in interfaceSerializer<UUID>
- Parameters:
configs
- configs in key/value pairsisKey
- whether is for key or value
-
serialize
public byte[] serialize(String topic, UUID data)
Description copied from interface:Serializer
Convertdata
into a byte array.- Specified by:
serialize
in interfaceSerializer<UUID>
- Parameters:
topic
- topic associated with datadata
- typed data- Returns:
- serialized bytes
-
-