Class UUIDDeserializer
- java.lang.Object
-
- org.apache.kafka.common.serialization.UUIDDeserializer
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Deserializer<UUID>
public class UUIDDeserializer extends Object implements Deserializer<UUID>
We are converting the byte array to String before deserializing to UUID. 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 UUIDDeserializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Map<String,?> configs, boolean isKey)
Configure this class.UUID
deserialize(String topic, byte[] data)
Deserialize a record value from a byte array into a value or object.-
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.Deserializer
close, deserialize
-
-
-
-
Method Detail
-
configure
public void configure(Map<String,?> configs, boolean isKey)
Description copied from interface:Deserializer
Configure this class.- Specified by:
configure
in interfaceDeserializer<UUID>
- Parameters:
configs
- configs in key/value pairsisKey
- whether is for key or value
-
deserialize
public UUID 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 interfaceDeserializer<UUID>
- Parameters:
topic
- topic associated with the datadata
- serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.- Returns:
- deserialized typed data; may be null
-
-