org.apache.kafka.common.security.auth

Interface KafkaPrincipalSerde

public interface KafkaPrincipalSerde

Serializer/Deserializer interface for KafkaPrincipal for the purpose of inter-broker forwarding. Any serialization/deserialization failure should raise a SerializationException to be consistent.

Method Summary

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.

Method Detail

serialize

byte[] serialize(KafkaPrincipal principal)
          throws SerializationException

Serialize a KafkaPrincipal into byte array.

Parameters:

principal - principal to be serialized

Returns:

serialized bytes

Throws:

SerializationException

deserialize

KafkaPrincipal deserialize(byte[] bytes)
                    throws SerializationException

Deserialize a KafkaPrincipal from byte array.

Parameters:

bytes - byte array to be deserialized

Returns:

the deserialized principal

Throws:

SerializationException