public class org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig extends org.apache.kafkaesqueesqueesque.common.config.AbstractConfig
{
private static final org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG;
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG;
private static final java.lang.String BOOTSTRAP_SERVERS_DOC;
public static final java.lang.String CLIENT_DNS_LOOKUP_CONFIG;
private static final java.lang.String CLIENT_DNS_LOOKUP_DOC;
public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG;
private static final java.lang.String RECONNECT_BACKOFF_MS_DOC;
public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG;
private static final java.lang.String RECONNECT_BACKOFF_MAX_MS_DOC;
public static final java.lang.String RETRY_BACKOFF_MS_CONFIG;
private static final java.lang.String RETRY_BACKOFF_MS_DOC;
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG;
private static final java.lang.String CONNECTIONS_MAX_IDLE_MS_DOC;
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG;
private static final java.lang.String REQUEST_TIMEOUT_MS_DOC;
public static final java.lang.String CLIENT_ID_CONFIG;
private static final java.lang.String CLIENT_ID_DOC;
public static final java.lang.String METADATA_MAX_AGE_CONFIG;
private static final java.lang.String METADATA_MAX_AGE_DOC;
public static final java.lang.String SEND_BUFFER_CONFIG;
private static final java.lang.String SEND_BUFFER_DOC;
public static final java.lang.String RECEIVE_BUFFER_CONFIG;
private static final java.lang.String RECEIVE_BUFFER_DOC;
public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG;
private static final java.lang.String METRIC_REPORTER_CLASSES_DOC;
public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG;
private static final java.lang.String METRICS_NUM_SAMPLES_DOC;
public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG;
private static final java.lang.String METRICS_SAMPLE_WINDOW_MS_DOC;
public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG;
public static final java.lang.String SECURITY_PROTOCOL_CONFIG;
public static final java.lang.String DEFAULT_SECURITY_PROTOCOL;
private static final java.lang.String SECURITY_PROTOCOL_DOC;
private static final java.lang.String METRICS_RECORDING_LEVEL_DOC;
public static final java.lang.String RETRIES_CONFIG;
public static final java.lang.String DEFAULT_API_TIMEOUT_MS_CONFIG;
public static final java.lang.String SECURITY_PROVIDERS_CONFIG;
private static final java.lang.String SECURITY_PROVIDERS_DOC;
protected java.util.Map postProcessParsedConfig(java.util.Map)
{
org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig v;
java.util.Map v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig;
v := @parameter: java.util.Map;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.CommonClientConfigs: java.util.Map postProcessReconnectBackoffConfigs(org.apache.kafkaesqueesqueesque.common.config.AbstractConfig,java.util.Map)>(v, v);
return v;
}
public void <init>(java.util.Map)
{
org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: void <init>(java.util.Map,boolean)>(v, 0);
return;
}
protected void <init>(java.util.Map, boolean)
{
org.apache.kafkaesqueesqueesque.common.config.ConfigDef v;
java.util.Map v;
org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig;
v := @parameter: java.util.Map;
v := @parameter: boolean;
v = <org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: void <init>(org.apache.kafkaesqueesqueesque.common.config.ConfigDef,java.util.Map,boolean)>(v, v, v);
return;
}
public static java.util.Set configNames()
{
java.util.Set v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef v;
v = <org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: java.util.Set names()>();
return v;
}
public static org.apache.kafkaesqueesqueesque.common.config.ConfigDef configDef()
{
org.apache.kafkaesqueesqueesque.common.config.ConfigDef v, v;
v = new org.apache.kafkaesqueesqueesque.common.config.ConfigDef;
v = <org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: void <init>(org.apache.kafkaesqueesqueesque.common.config.ConfigDef)>(v);
return v;
}
public static void main(java.lang.String[])
{
java.io.PrintStream v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef v;
java.lang.String[] v;
java.lang.String v;
v := @parameter: java.lang.String[];
v = <java.lang.System: java.io.PrintStream out>;
v = <org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: java.lang.String toHtml()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
return;
}
static void <clinit>()
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel v, v, v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v;
int v, v, v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.config.ConfigDef$ValidString v, v;
v = <org.apache.kafkaesqueesqueesque.clients.CommonClientConfigs: java.lang.String SECURITY_PROTOCOL_DOC>;
<org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: java.lang.String SECURITY_PROTOCOL_DOC> = v;
v = new org.apache.kafkaesqueesqueesque.common.config.ConfigDef;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: void <init>()>();
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LIST>;
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance HIGH>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("bootstrap.servers", v, v, "A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The client will make use of all servers irrespective of which servers are specified here for bootstrapping&mdash;this list only impacts the initial hosts used to discover the full set of servers. This list should be in the form <code>host1:port,host2:port,...</code>. Since these servers are just used for the initial connection to discover the full cluster membership (which may change dynamically), this list need not contain the full set of servers (you may want more than one, though, in case a server is down).");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("client.id", v, "", v, "An id string to pass to the server when making requests. The purpose of this is to be able to track the source of requests beyond just ip/port by allowing a logical application name to be included in server-side request logging.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(300000);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("metadata.max.age.ms", v, v, v, v, "The period of time in milliseconds after which we force a refresh of metadata even if we haven\'t seen any partition leadership changes to proactively discover any new brokers or partitions.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(131072);
v = (int) -1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("send.buffer.bytes", v, v, v, v, "The size of the TCP send buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default will be used.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(65536);
v = (int) -1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("receive.buffer.bytes", v, v, v, v, "The size of the TCP receive buffer (SO_RCVBUF) to use when reading data. If the value is -1, the OS default will be used.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(50L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("reconnect.backoff.ms", v, v, v, v, "The base amount of time to wait before attempting to reconnect to a given host. This avoids repeatedly connecting to a host in a tight loop. This backoff applies to all connection attempts by the client to a broker.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1000L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("reconnect.backoff.max.ms", v, v, v, v, "The maximum amount of time in milliseconds to wait when reconnecting to a broker that has repeatedly failed to connect. If provided, the backoff per host will increase exponentially for each consecutive connection failure, up to this maximum. After calculating the backoff increase, 20% random jitter is added to avoid connection storms.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("retry.backoff.ms", v, v, v, v, "The amount of time to wait before attempting to retry a failed request. This avoids repeatedly sending requests in a tight loop under some failure scenarios.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(30000);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("request.timeout.ms", v, v, v, v, "The configuration controls the maximum amount of time the client will wait for the response of a request. If the response is not received before the timeout elapses the client will resend the request if necessary or fail the request if retries are exhausted.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(300000);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("connections.max.idle.ms", v, v, v, "Close idle connections after the number of milliseconds specified by this config.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2147483647);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2147483647);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range between(java.lang.Number,java.lang.Number)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("retries", v, v, v, v, "Setting a value greater than zero will cause the client to resend any request that fails with a potentially transient error.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = (int) 60000;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("default.api.timeout.ms", v, v, v, v, "Specifies the timeout (in milliseconds) for client APIs. This configuration is used as the default timeout for all client operations that do not specify a <code>timeout</code> parameter.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LONG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(30000);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("metrics.sample.window.ms", v, v, v, v, "The window of time a metrics sample is computed over.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type INT>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Range atLeast(java.lang.Number)>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("metrics.num.samples", v, v, v, v, "The number of samples maintained to compute metrics.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type LIST>;
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("metric.reporters", v, "", v, "A list of classes to use as metrics reporters. Implementing the <code>org.apache.kafka.common.metrics.MetricsReporter</code> interface allows plugging in classes that will be notified of new metric creation. The JmxReporter is always included to register JMX statistics.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel INFO>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: java.lang.String toString()>();
v = newarray (java.lang.String)[2];
v = <org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel INFO>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: java.lang.String toString()>();
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel DEBUG>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel: java.lang.String toString()>();
v[1] = v;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$ValidString: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$ValidString in(java.lang.String[])>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("metrics.recording.level", v, v, v, v, "The highest recording level for metrics.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup DEFAULT>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: java.lang.String toString()>();
v = newarray (java.lang.String)[3];
v = <org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup DEFAULT>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: java.lang.String toString()>();
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup USE_ALL_DNS_IPS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: java.lang.String toString()>();
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup: java.lang.String toString()>();
v[2] = v;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$ValidString: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$ValidString in(java.lang.String[])>(v);
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Validator,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("client.dns.lookup", v, v, v, v, "Controls how the client uses DNS lookups. If set to <code>use_all_dns_ips</code> then, when the lookup returns multiple IP addresses for a hostname, they will all be attempted to connect to before failing the connection. Applies to both bootstrap and advertised servers. If the value is <code>resolve_canonical_bootstrap_servers_only</code> each entry will be resolved and expanded into a list of canonical names.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance LOW>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("security.providers", v, null, v, "A list of configurable creator classes each returning a provider implementing security algorithms. These classes should implement the <code>org.apache.kafka.common.security.auth.SecurityProviderCreator</code> interface.");
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type STRING>;
v = <org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance: org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance MEDIUM>;
v = <org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: java.lang.String SECURITY_PROTOCOL_DOC>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef define(java.lang.String,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Type,java.lang.Object,org.apache.kafkaesqueesqueesque.common.config.ConfigDef$Importance,java.lang.String)>("security.protocol", v, "PLAINTEXT", v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef withClientSslSupport()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.ConfigDef: org.apache.kafkaesqueesqueesque.common.config.ConfigDef withClientSaslSupport()>();
<org.apache.kafkaesqueesqueesque.clients.admin.AdminClientConfig: org.apache.kafkaesqueesqueesque.common.config.ConfigDef CONFIG> = v;
return;
}
}