public class org.apache.kafkaesque.clients.CommonClientConfigs extends java.lang.Object
{
private static final org.slf4j.Logger log;
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG;
public static final java.lang.String BOOTSTRAP_SERVERS_DOC;
public static final java.lang.String CLIENT_DNS_LOOKUP_CONFIG;
public static final java.lang.String CLIENT_DNS_LOOKUP_DOC;
public static final java.lang.String METADATA_MAX_AGE_CONFIG;
public static final java.lang.String METADATA_MAX_AGE_DOC;
public static final java.lang.String SEND_BUFFER_CONFIG;
public static final java.lang.String SEND_BUFFER_DOC;
public static final int SEND_BUFFER_LOWER_BOUND;
public static final java.lang.String RECEIVE_BUFFER_CONFIG;
public static final java.lang.String RECEIVE_BUFFER_DOC;
public static final int RECEIVE_BUFFER_LOWER_BOUND;
public static final java.lang.String CLIENT_ID_CONFIG;
public static final java.lang.String CLIENT_ID_DOC;
public static final java.lang.String CLIENT_RACK_CONFIG;
public static final java.lang.String CLIENT_RACK_DOC;
public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG;
public static final java.lang.String RECONNECT_BACKOFF_MS_DOC;
public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG;
public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_DOC;
public static final java.lang.String RETRIES_CONFIG;
public static final java.lang.String RETRIES_DOC;
public static final java.lang.String RETRY_BACKOFF_MS_CONFIG;
public static final java.lang.String RETRY_BACKOFF_MS_DOC;
public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG;
public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_DOC;
public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG;
public static final java.lang.String METRICS_NUM_SAMPLES_DOC;
public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG;
public static final java.lang.String METRICS_RECORDING_LEVEL_DOC;
public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG;
public static final java.lang.String METRIC_REPORTER_CLASSES_DOC;
public static final java.lang.String SECURITY_PROTOCOL_CONFIG;
public static final java.lang.String SECURITY_PROTOCOL_DOC;
public static final java.lang.String DEFAULT_SECURITY_PROTOCOL;
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG;
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_DOC;
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG;
public static final java.lang.String REQUEST_TIMEOUT_MS_DOC;
public static final java.lang.String GROUP_ID_CONFIG;
public static final java.lang.String GROUP_ID_DOC;
public static final java.lang.String GROUP_INSTANCE_ID_CONFIG;
public static final java.lang.String GROUP_INSTANCE_ID_DOC;
public static final java.lang.String MAX_POLL_INTERVAL_MS_CONFIG;
public static final java.lang.String MAX_POLL_INTERVAL_MS_DOC;
public static final java.lang.String REBALANCE_TIMEOUT_MS_CONFIG;
public static final java.lang.String REBALANCE_TIMEOUT_MS_DOC;
public static final java.lang.String SESSION_TIMEOUT_MS_CONFIG;
public static final java.lang.String SESSION_TIMEOUT_MS_DOC;
public static final java.lang.String HEARTBEAT_INTERVAL_MS_CONFIG;
public static final java.lang.String HEARTBEAT_INTERVAL_MS_DOC;
public static final java.lang.String DEFAULT_API_TIMEOUT_MS_CONFIG;
public static final java.lang.String DEFAULT_API_TIMEOUT_MS_DOC;
public void <init>()
{
org.apache.kafkaesque.clients.CommonClientConfigs v;
v := @this: org.apache.kafkaesque.clients.CommonClientConfigs;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.util.Map postProcessReconnectBackoffConfigs(org.apache.kafkaesque.common.config.AbstractConfig, java.util.Map)
{
org.slf4j.Logger v;
java.util.HashMap v;
java.util.Map v, v, v;
org.apache.kafkaesque.common.config.AbstractConfig v;
java.lang.Object v;
boolean v, v;
v := @parameter: org.apache.kafkaesque.common.config.AbstractConfig;
v := @parameter: java.util.Map;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.config.AbstractConfig: java.util.Map originals()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("reconnect.backoff.max.ms");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.config.AbstractConfig: java.util.Map originals()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("reconnect.backoff.ms");
if v == 0 goto label;
v = <org.apache.kafkaesque.clients.CommonClientConfigs: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Disabling exponential reconnect backoff because {} is set, but {} is not.", "reconnect.backoff.ms", "reconnect.backoff.max.ms");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("reconnect.backoff.ms");
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("reconnect.backoff.max.ms", v);
label:
return v;
}
static void <clinit>()
{
java.util.List v;
org.slf4j.Logger v;
java.lang.String v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/kafkaesque/clients/CommonClientConfigs;");
<org.apache.kafkaesque.clients.CommonClientConfigs: org.slf4j.Logger log> = v;
v = staticinvoke <org.apache.kafkaesque.common.security.auth.SecurityProtocol: java.util.List names()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Protocol used to communicate with brokers. Valid values are: \u.");
<org.apache.kafkaesque.clients.CommonClientConfigs: java.lang.String SECURITY_PROTOCOL_DOC> = v;
return;
}
}