All Known Subinterfaces:: KafkaPrincipalBuilder

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
Description
KafkaPrincipal
deserialize(byte[] bytes)
Deserialize a KafkaPrincipal from byte array.
byte[]
serialize(KafkaPrincipal principal)
Serialize a KafkaPrincipal into byte array.

Method Details
- 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

Interface KafkaPrincipalSerde

Method Summary

Method Details

serialize

deserialize