public class org.apache.kafkaesque.common.config.SaslConfigs extends java.lang.Object
{
public static final java.lang.String SASL_MECHANISM;
public static final java.lang.String SASL_MECHANISM_DOC;
public static final java.lang.String GSSAPI_MECHANISM;
public static final java.lang.String DEFAULT_SASL_MECHANISM;
public static final java.lang.String SASL_ENABLED_MECHANISMS;
public static final java.lang.String SASL_ENABLED_MECHANISMS_DOC;
public static final java.util.List DEFAULT_SASL_ENABLED_MECHANISMS;
public static final java.lang.String SASL_JAAS_CONFIG;
public static final java.lang.String SASL_JAAS_CONFIG_DOC;
public static final java.lang.String SASL_CLIENT_CALLBACK_HANDLER_CLASS;
public static final java.lang.String SASL_CLIENT_CALLBACK_HANDLER_CLASS_DOC;
public static final java.lang.String SASL_LOGIN_CALLBACK_HANDLER_CLASS;
public static final java.lang.String SASL_LOGIN_CALLBACK_HANDLER_CLASS_DOC;
public static final java.lang.String SASL_LOGIN_CLASS;
public static final java.lang.String SASL_LOGIN_CLASS_DOC;
public static final java.lang.String SASL_KERBEROS_SERVICE_NAME;
public static final java.lang.String SASL_KERBEROS_SERVICE_NAME_DOC;
public static final java.lang.String SASL_KERBEROS_KINIT_CMD;
public static final java.lang.String SASL_KERBEROS_KINIT_CMD_DOC;
public static final java.lang.String DEFAULT_KERBEROS_KINIT_CMD;
public static final java.lang.String SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR;
public static final java.lang.String SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC;
public static final double DEFAULT_KERBEROS_TICKET_RENEW_WINDOW_FACTOR;
public static final java.lang.String SASL_KERBEROS_TICKET_RENEW_JITTER;
public static final java.lang.String SASL_KERBEROS_TICKET_RENEW_JITTER_DOC;
public static final double DEFAULT_KERBEROS_TICKET_RENEW_JITTER;
public static final java.lang.String SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN;
public static final java.lang.String SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC;
public static final long DEFAULT_KERBEROS_MIN_TIME_BEFORE_RELOGIN;
public static final java.lang.String SASL_LOGIN_REFRESH_WINDOW_FACTOR;
public static final java.lang.String SASL_LOGIN_REFRESH_WINDOW_FACTOR_DOC;
public static final double DEFAULT_LOGIN_REFRESH_WINDOW_FACTOR;
public static final java.lang.String SASL_LOGIN_REFRESH_WINDOW_JITTER;
public static final java.lang.String SASL_LOGIN_REFRESH_WINDOW_JITTER_DOC;
public static final double DEFAULT_LOGIN_REFRESH_WINDOW_JITTER;
public static final java.lang.String SASL_LOGIN_REFRESH_MIN_PERIOD_SECONDS;
public static final java.lang.String SASL_LOGIN_REFRESH_MIN_PERIOD_SECONDS_DOC;
public static final short DEFAULT_LOGIN_REFRESH_MIN_PERIOD_SECONDS;
public static final java.lang.String SASL_LOGIN_REFRESH_BUFFER_SECONDS;
public static final java.lang.String SASL_LOGIN_REFRESH_BUFFER_SECONDS_DOC;
public static final short DEFAULT_LOGIN_REFRESH_BUFFER_SECONDS;
public static final java.lang.String SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES;
public static final java.lang.String SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_DOC;
public static final java.util.List DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES;
public void <init>()
{
org.apache.kafkaesque.common.config.SaslConfigs v;
v := @this: org.apache.kafkaesque.common.config.SaslConfigs;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void addClientSaslSupport(org.apache.kafkaesque.common.config.ConfigDef)
{
org.apache.kafkaesque.common.config.ConfigDef$Range v, v, v, v;
java.lang.Integer v, v, v, v;
java.lang.Long v;
org.apache.kafkaesque.common.config.ConfigDef$Type v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Short v, v;
org.apache.kafkaesque.common.config.ConfigDef v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Double v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.config.ConfigDef$Importance v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @parameter: org.apache.kafkaesque.common.config.ConfigDef;
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.kerberos.service.name", v, null, v, "The Kerberos principal name that Kafka runs as. This can be defined either in Kafka\'s JAAS config or in Kafka\'s config.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.kerberos.kinit.cmd", v, "/usr/bin/kinit", v, "Kerberos kinit command path.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type DOUBLE>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.8);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.kerberos.ticket.renew.window.factor", v, v, v, "Login thread will sleep until the specified window factor of time from last refresh to ticket\'s expiry has been reached, at which time it will try to renew the ticket.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type DOUBLE>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.05);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.kerberos.ticket.renew.jitter", v, v, v, "Percentage of random jitter added to the renewal time.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(60000L);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.kerberos.min.time.before.relogin", v, v, v, "Login thread sleep time between refresh attempts.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type DOUBLE>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.8);
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.5);
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(1.0);
v = staticinvoke <org.apache.kafkaesque.common.config.ConfigDef$Range: org.apache.kafkaesque.common.config.ConfigDef$Range between(java.lang.Number,java.lang.Number)>(v, v);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Validator,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.refresh.window.factor", v, v, v, v, "Login refresh thread will sleep until the specified window factor relative to the credential\'s lifetime has been reached, at which time it will try to refresh the credential. Legal values are between 0.5 (50%) and 1.0 (100%) inclusive; a default value of 0.8 (80%) is used if no value is specified. Currently applies only to OAUTHBEARER.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type DOUBLE>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.05);
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.0);
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.25);
v = staticinvoke <org.apache.kafkaesque.common.config.ConfigDef$Range: org.apache.kafkaesque.common.config.ConfigDef$Range between(java.lang.Number,java.lang.Number)>(v, v);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Validator,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.refresh.window.jitter", v, v, v, v, "The maximum amount of random jitter relative to the credential\'s lifetime that is added to the login refresh thread\'s sleep time. Legal values are between 0 and 0.25 (25%) inclusive; a default value of 0.05 (5%) is used if no value is specified. Currently applies only to OAUTHBEARER.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type SHORT>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(60);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(900);
v = staticinvoke <org.apache.kafkaesque.common.config.ConfigDef$Range: org.apache.kafkaesque.common.config.ConfigDef$Range between(java.lang.Number,java.lang.Number)>(v, v);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Validator,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.refresh.min.period.seconds", v, v, v, v, "The desired minimum time for the login refresh thread to wait before refreshing a credential, in seconds. Legal values are between 0 and 900 (15 minutes); a default value of 60 (1 minute) is used if no value is specified.  This value and  sasl.login.refresh.buffer.seconds are both ignored if their sum exceeds the remaining lifetime of a credential. Currently applies only to OAUTHBEARER.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type SHORT>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(300);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3600);
v = staticinvoke <org.apache.kafkaesque.common.config.ConfigDef$Range: org.apache.kafkaesque.common.config.ConfigDef$Range between(java.lang.Number,java.lang.Number)>(v, v);
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Validator,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.refresh.buffer.seconds", v, v, v, v, "The amount of buffer time before credential expiration to maintain when refreshing a credential, in seconds. If a refresh would otherwise occur closer to expiration than the number of buffer seconds then the refresh will be moved up to maintain as much of the buffer time as possible. Legal values are between 0 and 3600 (1 hour); a default value of  300 (5 minutes) is used if no value is specified. This value and sasl.login.refresh.min.period.seconds are both ignored if their sum exceeds the remaining lifetime of a credential. Currently applies only to OAUTHBEARER.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.mechanism", v, "GSSAPI", v, "SASL mechanism used for client connections. This may be any mechanism for which a security provider is available. GSSAPI is the default mechanism.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type PASSWORD>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.jaas.config", v, null, v, "JAAS login context parameters for SASL connections in the format used by JAAS configuration files. JAAS configuration file format is described <a href=\"http://docs.oracle.com/javase/8/docs/technotes/guides/security/jgss/tutorials/LoginConfigFile.html\">here</a>. The format for the value is: \'<code>loginModuleClass controlFlag (optionName=optionValue)*;</code>\'. For brokers, the config must be prefixed with listener prefix and SASL mechanism name in lower-case. For example, listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule required;");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type CLASS>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.client.callback.handler.class", v, null, v, "The fully qualified name of a SASL client callback handler class that implements the AuthenticateCallbackHandler interface.");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type CLASS>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.callback.handler.class", v, null, v, "The fully qualified name of a SASL login callback handler class that implements the AuthenticateCallbackHandler interface. For brokers, login callback handler config must be prefixed with listener prefix and SASL mechanism name in lower-case. For example, listener.name.sasl_ssl.scram-sha-256.sasl.login.callback.handler.class=com.example.CustomScramLoginCallbackHandler");
v = <org.apache.kafkaesque.common.config.ConfigDef$Type: org.apache.kafkaesque.common.config.ConfigDef$Type CLASS>;
v = <org.apache.kafkaesque.common.config.ConfigDef$Importance: org.apache.kafkaesque.common.config.ConfigDef$Importance MEDIUM>;
virtualinvoke v.<org.apache.kafkaesque.common.config.ConfigDef: org.apache.kafkaesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesque.common.config.ConfigDef$Importance,java.lang.String)>("sasl.login.class", v, null, v, "The fully qualified name of a class that implements the Login interface. For brokers, login config must be prefixed with listener prefix and SASL mechanism name in lower-case. For example, listener.name.sasl_ssl.scram-sha-256.sasl.login.class=com.example.CustomScramLogin");
return;
}
static void <clinit>()
{
java.util.List v, v;
v = <org.apache.kafkaesque.common.config.internals.BrokerSecurityConfigs: java.util.List DEFAULT_SASL_ENABLED_MECHANISMS>;
<org.apache.kafkaesque.common.config.SaslConfigs: java.util.List DEFAULT_SASL_ENABLED_MECHANISMS> = v;
v = <org.apache.kafkaesque.common.config.internals.BrokerSecurityConfigs: java.util.List DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES>;
<org.apache.kafkaesque.common.config.SaslConfigs: java.util.List DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES> = v;
return;
}
}