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.