public interface KafkaPrincipalSerdeKafkaPrincipal for the purpose of inter-broker forwarding. Any serialization/deserialization failure should raise a SerializationException to be consistent.| Modifier and Type | Method and Description |
|---|---|
KafkaPrincipal | deserialize(byte[] bytes)Deserialize a KafkaPrincipal from byte array. |
byte[] | serialize(KafkaPrincipal principal)Serialize a KafkaPrincipal into byte array. |
byte[] serialize(KafkaPrincipal principal) throws SerializationException
KafkaPrincipal into byte array.principal - principal to be serializedSerializationExceptionKafkaPrincipal deserialize(byte[] bytes) throws SerializationException
KafkaPrincipal from byte array.bytes - byte array to be deserializedSerializationException