public interface KafkaPrincipalSerde
KafkaPrincipal
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 serializedSerializationException
KafkaPrincipal deserialize(byte[] bytes) throws SerializationException
KafkaPrincipal
from byte array.bytes
- byte array to be deserializedSerializationException