Interface KafkaPrincipalSerde
-
public interface KafkaPrincipalSerdeSerializer/Deserializer interface forKafkaPrincipalfor the the purpose of inter-broker forwarding. Any serialization/deserialization failure should raise aSerializationExceptionto be consistent.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description KafkaPrincipaldeserialize(byte[] bytes)Deserialize aKafkaPrincipalfrom byte array.byte[]serialize(KafkaPrincipal principal)Serialize aKafkaPrincipalinto byte array.
-
-
-
Method Detail
-
serialize
byte[] serialize(KafkaPrincipal principal) throws SerializationException
Serialize aKafkaPrincipalinto byte array.- Parameters:
principal- principal to be serialized- Returns:
- serialized bytes
- Throws:
SerializationException
-
deserialize
KafkaPrincipal deserialize(byte[] bytes) throws SerializationException
Deserialize aKafkaPrincipalfrom byte array.- Parameters:
bytes- byte array to be deserialized- Returns:
- the deserialized principal
- Throws:
SerializationException
-
-