Class QuorumAuth


  • public class QuorumAuth
    extends java.lang.Object
    • Field Detail

      • QUORUM_SASL_AUTH_ENABLED

        public static final java.lang.String QUORUM_SASL_AUTH_ENABLED
        See Also:
        Constant Field Values
      • QUORUM_SERVER_SASL_AUTH_REQUIRED

        public static final java.lang.String QUORUM_SERVER_SASL_AUTH_REQUIRED
        See Also:
        Constant Field Values
      • QUORUM_LEARNER_SASL_AUTH_REQUIRED

        public static final java.lang.String QUORUM_LEARNER_SASL_AUTH_REQUIRED
        See Also:
        Constant Field Values
      • QUORUM_KERBEROS_SERVICE_PRINCIPAL

        public static final java.lang.String QUORUM_KERBEROS_SERVICE_PRINCIPAL
        See Also:
        Constant Field Values
      • QUORUM_KERBEROS_SERVICE_PRINCIPAL_DEFAULT_VALUE

        public static final java.lang.String QUORUM_KERBEROS_SERVICE_PRINCIPAL_DEFAULT_VALUE
        See Also:
        Constant Field Values
      • QUORUM_LEARNER_SASL_LOGIN_CONTEXT

        public static final java.lang.String QUORUM_LEARNER_SASL_LOGIN_CONTEXT
        See Also:
        Constant Field Values
      • QUORUM_LEARNER_SASL_LOGIN_CONTEXT_DFAULT_VALUE

        public static final java.lang.String QUORUM_LEARNER_SASL_LOGIN_CONTEXT_DFAULT_VALUE
        See Also:
        Constant Field Values
      • QUORUM_SERVER_SASL_LOGIN_CONTEXT

        public static final java.lang.String QUORUM_SERVER_SASL_LOGIN_CONTEXT
        See Also:
        Constant Field Values
      • QUORUM_SERVER_SASL_LOGIN_CONTEXT_DFAULT_VALUE

        public static final java.lang.String QUORUM_SERVER_SASL_LOGIN_CONTEXT_DFAULT_VALUE
        See Also:
        Constant Field Values
      • QUORUM_AUTH_MAGIC_NUMBER

        public static final long QUORUM_AUTH_MAGIC_NUMBER
        See Also:
        Constant Field Values
    • Constructor Detail

      • QuorumAuth

        public QuorumAuth()
    • Method Detail

      • nextPacketIsAuth

        public static boolean nextPacketIsAuth​(java.io.DataInputStream din)
                                        throws java.io.IOException
        Throws:
        java.io.IOException