apache-kafka_0_10-lib/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java
public void configure(Map<String, ?> configs, final String loginContextName) {
    super.configure(configs, loginContextName);
    this.loginContextName = loginContextName;
    this.ticketRenewWindowFactor = (Double) configs.get(SaslConfigs.SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR);
    this.ticketRenewJitter = (Double) configs.get(SaslConfigs.SASL_KERBEROS_TICKET_RENEW_JITTER);
    this.minTimeBeforeRelogin = (Long) configs.get(SaslConfigs.SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN);
    this.kinitCmd = (String) configs.get(SaslConfigs.SASL_KERBEROS_KINIT_CMD);
    this.serviceName = getServiceName(configs, loginContextName);
  }
public void configure(Map<String, ?> configs, final String loginContextName) {
    super.configure(configs, loginContextName);
    this.loginContextName = loginContextName;
    this.ticketRenewWindowFactor = (Double) configs.get(SaslConfigs.SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR);
    this.ticketRenewJitter = (Double) configs.get(SaslConfigs.SASL_KERBEROS_TICKET_RENEW_JITTER);
    this.minTimeBeforeRelogin = (Long) configs.get(SaslConfigs.SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN);
    this.kinitCmd = (String) configs.get(SaslConfigs.SASL_KERBEROS_KINIT_CMD);
    this.serviceName = getServiceName(configs, loginContextName);
  }
public void configure ( Map < String , ? > configs , final String loginContextName ) { super . configure ( configs , loginContextName ) ; this . loginContextName = loginContextName ; this . ticketRenewWindowFactor = ( Double ) configs . get ( SaslConfigs . SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR ) ; this . ticketRenewJitter = ( Double ) configs . get ( SaslConfigs . SASL_KERBEROS_TICKET_RENEW_JITTER ) ; this . minTimeBeforeRelogin = ( Long ) configs . get ( SaslConfigs . SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN ) ; this . kinitCmd = ( String ) configs . get ( SaslConfigs . SASL_KERBEROS_KINIT_CMD ) ; this . serviceName = getServiceName ( configs , loginContextName ) ; }
Login constructor. The constructor starts the thread used
to periodically re-login to the Kerberos Ticket Granting Server.
@param loginContextName
name of section in JAAS file that will be use to login.
Passed as first param to javax.security.auth.login.LoginContext().
@param configs configure Login with the given key-value pairs.
@throws javax.security.auth.login.LoginException
Thrown if authentication fails.
Login constructor . The constructor starts the thread used to periodically re - login to the Kerberos Ticket Granting Server .