public class org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient extends org.apache.kafkaesqueesque.clients.admin.AdminClient
{
private static final java.util.concurrent.atomic.AtomicInteger ADMIN_CLIENT_ID_SEQUENCE;
private static final java.lang.String JMX_PREFIX;
private static final long INVALID_SHUTDOWN_TIME;
static final java.lang.String NETWORK_THREAD_PREFIX;
private final org.slf4j.Logger log;
private final int defaultApiTimeoutMs;
private final int requestTimeoutMs;
private final java.lang.String clientId;
private final org.apache.kafkaesqueesque.common.utils.Time time;
private final org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager metadataManager;
private final org.apache.kafkaesqueesque.common.metrics.Metrics metrics;
private final org.apache.kafkaesqueesque.clients.KafkaClient client;
private final org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable;
private final java.lang.Thread thread;
private final java.util.concurrent.atomic.AtomicLong hardShutdownTimeMs;
private final org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory timeoutProcessorFactory;
private final int maxRetries;
private final long retryBackoffMs;
static java.util.List getOrCreateListValue(java.util.Map, java.lang.Object)
{
java.util.Map v;
java.lang.Object v, v;
java.util.function.Function v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.Object;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_getOrCreateListValue_0__505: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
return v;
}
private static void completeAllExceptionally(java.util.Collection, java.lang.Throwable)
{
java.lang.Throwable v;
java.util.stream.Stream v;
java.util.Collection v;
v := @parameter: java.util.Collection;
v := @parameter: java.lang.Throwable;
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: void completeAllExceptionally(java.util.stream.Stream,java.lang.Throwable)>(v, v);
return;
}
private static void completeAllExceptionally(java.util.stream.Stream, java.lang.Throwable)
{
java.lang.Throwable v;
java.util.function.Consumer v;
java.util.stream.Stream v;
v := @parameter: java.util.stream.Stream;
v := @parameter: java.lang.Throwable;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_completeAllExceptionally_1__506: java.util.function.Consumer bootstrap$(java.lang.Throwable)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return;
}
static int calcTimeoutMsRemainingAsInt(long, long)
{
byte v, v;
long v, v, v;
v := @parameter: long;
v := @parameter: long;
v = v - v;
v = v cmp 2147483647L;
if v <= 0 goto label;
v = 2147483647L;
goto label;
label:
v = v cmp -2147483648L;
if v >= 0 goto label;
v = -2147483648L;
label:
return v;
}
static java.lang.String generateClientId(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig)
{
java.util.concurrent.atomic.AtomicInteger v;
int v;
java.lang.String v, v;
org.apache.kafkaesqueesque.clients.admin.AdminClientConfig v;
boolean v;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AdminClientConfig;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.String getString(java.lang.String)>("client.id");
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
return v;
label:
v = <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.concurrent.atomic.AtomicInteger ADMIN_CLIENT_ID_SEQUENCE>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int getAndIncrement()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("adminclient-\u0001");
return v;
}
private long calcDeadlineMs(long, java.lang.Integer)
{
long v, v, v;
java.lang.Integer v;
int v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: long;
v := @parameter: java.lang.Integer;
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = staticinvoke <java.lang.Math: int max(int,int)>(0, v);
v = v + v;
return v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int defaultApiTimeoutMs>;
v = v + v;
return v;
}
static java.lang.String prettyPrintException(java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.Class v, v;
java.lang.String v, v, v, v, v;
v := @parameter: java.lang.Throwable;
if v != null goto label;
return "Null exception.";
label:
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001: \u0001");
return v;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
return v;
}
static org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient createInternal(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig, org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory)
{
java.lang.Integer v, v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.lang.Long v, v, v, v, v, v;
java.util.Map v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager$AdminMetadataUpdater v;
org.apache.kafkaesqueesque.clients.NetworkClient v, v;
org.apache.kafkaesqueesque.common.metrics.Sensor$RecordingLevel v;
org.apache.kafkaesqueesque.common.metrics.JmxReporter v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory v;
java.util.List v, v, v;
org.apache.kafkaesqueesque.clients.admin.AdminClientConfig v;
java.lang.Throwable v;
org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager v;
org.apache.kafkaesqueesque.common.network.Selector v, v;
long v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.clients.ClientDnsLookup v;
org.apache.kafkaesqueesque.common.metrics.Metrics v, v;
int v, v, v;
java.lang.String v, v, v, v;
org.apache.kafkaesqueesque.clients.ApiVersions v;
org.apache.kafkaesqueesque.common.metrics.MetricConfig v, v, v, v, v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
java.util.concurrent.TimeUnit v, v;
org.apache.kafkaesqueesque.common.Cluster v;
org.apache.kafkaesqueesque.common.KafkaException v;
org.apache.kafkaesqueesque.common.network.ChannelBuilder v;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AdminClientConfig;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory;
v = null;
v = null;
v = <org.apache.kafkaesqueesque.common.utils.Time: org.apache.kafkaesqueesque.common.utils.Time SYSTEM>;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.String generateClientId(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig)>(v);
v = null;
v = null;
v = new org.apache.kafkaesqueesque.clients.ApiVersions;
specialinvoke v.<org.apache.kafkaesqueesque.clients.ApiVersions: void <init>()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.LogContext createLogContext(java.lang.String)>(v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("retry.backoff.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("metadata.max.age.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager: void <init>(org.apache.kafkaesqueesque.common.utils.LogContext,long,long)>(v, v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.util.List getList(java.lang.String)>("bootstrap.servers");
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.String getString(java.lang.String)>("client.dns.lookup");
v = staticinvoke <org.apache.kafkaesqueesque.clients.ClientUtils: java.util.List parseAndValidateAddresses(java.util.List,java.lang.String)>(v, v);
v = staticinvoke <org.apache.kafkaesqueesque.common.Cluster: org.apache.kafkaesqueesque.common.Cluster bootstrap(java.util.List)>(v);
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager: void update(org.apache.kafkaesqueesque.common.Cluster,long)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("client.id", v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.util.List getConfiguredInstances(java.lang.String,java.lang.Class,java.util.Map)>("metric.reporters", class "Lorg/apache/kafkaesqueesque/common/metrics/MetricsReporter;", v);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("client-id", v);
v = new org.apache.kafkaesqueesque.common.metrics.MetricConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("metrics.num.samples");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: org.apache.kafkaesqueesque.common.metrics.MetricConfig samples(int)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("metrics.sample.window.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: org.apache.kafkaesqueesque.common.metrics.MetricConfig timeWindow(long,java.util.concurrent.TimeUnit)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.String getString(java.lang.String)>("metrics.recording.level");
v = staticinvoke <org.apache.kafkaesqueesque.common.metrics.Sensor$RecordingLevel: org.apache.kafkaesqueesque.common.metrics.Sensor$RecordingLevel forName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: org.apache.kafkaesqueesque.common.metrics.MetricConfig recordLevel(org.apache.kafkaesqueesque.common.metrics.Sensor$RecordingLevel)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: org.apache.kafkaesqueesque.common.metrics.MetricConfig tags(java.util.Map)>(v);
v = new org.apache.kafkaesqueesque.common.metrics.JmxReporter;
specialinvoke v.<org.apache.kafkaesqueesque.common.metrics.JmxReporter: void <init>(java.lang.String)>("kafka.admin.client");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.kafkaesqueesque.common.metrics.Metrics;
specialinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: void <init>(org.apache.kafkaesqueesque.common.metrics.MetricConfig,java.util.List,org.apache.kafkaesqueesque.common.utils.Time)>(v, v, v);
v = v;
v = staticinvoke <org.apache.kafkaesqueesque.clients.ClientUtils: org.apache.kafkaesqueesque.common.network.ChannelBuilder createChannelBuilder(org.apache.kafkaesqueesque.common.config.AbstractConfig,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v);
v = new org.apache.kafkaesqueesque.common.network.Selector;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("connections.max.idle.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.network.Selector: void <init>(long,org.apache.kafkaesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesque.common.utils.Time,java.lang.String,org.apache.kafkaesqueesque.common.network.ChannelBuilder,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, "admin-client", v, v);
v = v;
v = new org.apache.kafkaesqueesque.clients.NetworkClient;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager$AdminMetadataUpdater updater()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("reconnect.backoff.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("reconnect.backoff.max.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("send.buffer.bytes");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("receive.buffer.bytes");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit HOURS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(1L);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.String getString(java.lang.String)>("client.dns.lookup");
v = staticinvoke <org.apache.kafkaesqueesque.clients.ClientDnsLookup: org.apache.kafkaesqueesque.clients.ClientDnsLookup forConfig(java.lang.String)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.NetworkClient: void <init>(org.apache.kafkaesqueesque.common.network.Selectable,org.apache.kafkaesqueesque.clients.MetadataUpdater,java.lang.String,int,long,long,int,int,int,org.apache.kafkaesqueesque.clients.ClientDnsLookup,org.apache.kafkaesqueesque.common.utils.Time,boolean,org.apache.kafkaesqueesque.clients.ApiVersions,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, 1, v, v, v, v, v, v, v, 1, v, v);
v = v;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: void <init>(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig,java.lang.String,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager,org.apache.kafkaesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesque.clients.KafkaClient,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v, v, v, v, v);
label:
return v;
label:
v := @caughtexception;
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void closeQuietly(java.lang.AutoCloseable,java.lang.String)>(v, "Metrics");
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void closeQuietly(java.lang.AutoCloseable,java.lang.String)>(v, "NetworkClient");
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void closeQuietly(java.lang.AutoCloseable,java.lang.String)>(v, "Selector");
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void closeQuietly(java.lang.AutoCloseable,java.lang.String)>(v, "ChannelBuilder");
v = new org.apache.kafkaesqueesque.common.KafkaException;
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to create new KafkaAdminClient", v);
throw v;
catch java.lang.Throwable from label to label with label;
}
static org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient createInternal(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig, org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager, org.apache.kafkaesqueesque.clients.KafkaClient, org.apache.kafkaesqueesque.common.utils.Time)
{
java.lang.Throwable v;
org.apache.kafkaesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesque.common.metrics.MetricConfig v;
org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
org.apache.kafkaesqueesque.common.metrics.Metrics v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.KafkaException v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
java.util.LinkedList v;
org.apache.kafkaesqueesque.clients.admin.AdminClientConfig v;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AdminClientConfig;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager;
v := @parameter: org.apache.kafkaesqueesque.clients.KafkaClient;
v := @parameter: org.apache.kafkaesqueesque.common.utils.Time;
v = null;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.String generateClientId(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig)>(v);
label:
v = new org.apache.kafkaesqueesque.common.metrics.Metrics;
v = new org.apache.kafkaesqueesque.common.metrics.MetricConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: void <init>()>();
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: void <init>(org.apache.kafkaesqueesque.common.metrics.MetricConfig,java.util.List,org.apache.kafkaesqueesque.common.utils.Time)>(v, v, v);
v = v;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.LogContext createLogContext(java.lang.String)>(v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: void <init>(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig,java.lang.String,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager,org.apache.kafkaesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesque.clients.KafkaClient,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v, v, v, null, v);
label:
return v;
label:
v := @caughtexception;
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void closeQuietly(java.lang.AutoCloseable,java.lang.String)>(v, "Metrics");
v = new org.apache.kafkaesqueesque.common.KafkaException;
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to create new KafkaAdminClient", v);
throw v;
catch java.lang.Throwable from label to label with label;
}
static org.apache.kafkaesqueesque.common.utils.LogContext createLogContext(java.lang.String)
{
java.lang.String v, v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
v := @parameter: java.lang.String;
v = new org.apache.kafkaesqueesque.common.utils.LogContext;
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[])>("[AdminClient clientId=\u] ");
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.LogContext: void <init>(java.lang.String)>(v);
return v;
}
private void <init>(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig, java.lang.String, org.apache.kafkaesqueesque.common.utils.Time, org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager, org.apache.kafkaesqueesque.common.metrics.Metrics, org.apache.kafkaesqueesque.clients.KafkaClient, org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory, org.apache.kafkaesqueesque.common.utils.LogContext)
{
org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager v;
long v, v;
java.lang.Integer v, v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.lang.Long v;
org.apache.kafkaesqueesque.common.utils.KafkaThread v;
java.lang.Thread v;
int v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
org.apache.kafkaesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v, v;
org.slf4j.Logger v, v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory v, v;
org.apache.kafkaesqueesque.clients.admin.AdminClientConfig v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AdminClientConfig;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.common.utils.Time;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager;
v := @parameter: org.apache.kafkaesqueesque.common.metrics.Metrics;
v := @parameter: org.apache.kafkaesqueesque.clients.KafkaClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory;
v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClient: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(-1L);
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.concurrent.atomic.AtomicLong hardShutdownTimeMs> = v;
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.String clientId> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.utils.LogContext: org.slf4j.Logger logger(java.lang.Class)>(class "Lorg/apache/kafkaesqueesque/clients/admin/KafkaAdminClient;");
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("request.timeout.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int requestTimeoutMs> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int configureDefaultApiTimeoutMs(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig)>(v);
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int defaultApiTimeoutMs> = v;
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time> = v;
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager metadataManager> = v;
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.metrics.Metrics metrics> = v;
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.KafkaClient client> = v;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable> = 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[])>("kafka-admin-client-thread | \u0001");
v = new org.apache.kafkaesqueesque.common.utils.KafkaThread;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.KafkaThread: void <init>(java.lang.String,java.lang.Runnable,boolean)>(v, v, 1);
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.Thread thread> = v;
if v != null goto label;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory: void <init>()>();
goto label;
label:
v = v;
label:
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory timeoutProcessorFactory> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("retries");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int maxRetries> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Long getLong(java.lang.String)>("retry.backoff.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long retryBackoffMs> = v;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: void logUnused()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
staticinvoke <org.apache.kafkaesqueesque.common.utils.AppInfoParser: void registerAppInfo(java.lang.String,java.lang.String,org.apache.kafkaesqueesque.common.metrics.Metrics,long)>("kafka.admin.client", v, v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Kafka admin client initialized");
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.Thread thread>;
virtualinvoke v.<java.lang.Thread: void start()>();
return;
}
private int configureDefaultApiTimeoutMs(org.apache.kafkaesqueesque.clients.admin.AdminClientConfig)
{
java.lang.Object[] v;
org.slf4j.Logger v;
java.lang.Integer v, v, v, v;
java.util.Map v;
int v, v, v;
org.apache.kafkaesqueesque.common.config.ConfigException v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.AdminClientConfig v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AdminClientConfig;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("request.timeout.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.lang.Integer getInt(java.lang.String)>("default.api.timeout.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AdminClientConfig: java.util.Map originals()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("default.api.timeout.ms");
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.config.ConfigException;
specialinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigException: void <init>(java.lang.String)>("The specified value of default.api.timeout.ms must be no smaller than the value of request.timeout.ms.");
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = "default.api.timeout.ms";
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: int defaultApiTimeoutMs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object[])>("Overriding the default value for {} ({}) with the explicitly configured request timeout {}", v);
return v;
label:
return v;
}
public void close(java.time.Duration)
{
org.apache.kafkaesqueesque.common.utils.Time v, v;
byte v, v, v;
java.lang.Long v;
java.lang.Thread v, v, v, v;
java.time.Duration v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v, v;
org.apache.kafkaesqueesque.clients.KafkaClient v;
long v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v;
java.lang.IllegalArgumentException v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.atomic.AtomicLong v, v;
java.lang.InterruptedException v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = v cmp 0L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The timeout cannot be negative.");
throw v;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit DAYS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(365L);
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v + v;
v = -1L;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.concurrent.atomic.AtomicLong hardShutdownTimeMs>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: boolean compareAndSet(long,long)>(v, v);
if v == 0 goto label;
v = v cmp -1L;
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Initiating close operation.");
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Moving hard shutdown time forward.");
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesque.clients.KafkaClient: void wakeup()>();
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.concurrent.atomic.AtomicLong hardShutdownTimeMs>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v >= 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Hard shutdown time is already earlier than requested.");
v = v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v - v;
v = staticinvoke <java.lang.Math: long max(long,long)>(0L, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Waiting for the I/O thread to exit. Hard shutdown in {} ms.", v);
label:
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.Thread thread>;
if v == v goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.lang.Thread thread>;
virtualinvoke v.<java.lang.Thread: void join(long)>(v);
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Kafka admin client closed.");
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Interrupted while joining I/O thread", v);
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
private static boolean topicNameIsUnrepresentable(java.lang.String)
{
java.lang.String v;
boolean v, v;
v := @parameter: java.lang.String;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private static boolean groupIdIsUnrepresentable(java.lang.String)
{
java.lang.String v;
boolean v;
v := @parameter: java.lang.String;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
int numPendingCalls()
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: java.util.ArrayList pendingCalls>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
return v;
}
public org.apache.kafkaesqueesque.clients.admin.CreateTopicsResult createTopics(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.CreateTopicsOptions)
{
org.apache.kafkaesqueesque.clients.admin.CreateTopicsOptions v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection v;
java.util.Collection v;
org.apache.kafkaesqueesque.common.errors.InvalidTopicException v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$1 v;
org.apache.kafkaesqueesque.clients.admin.CreateTopicsResult v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.CreateTopicsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: java.lang.String name()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean topicNameIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: java.lang.String name()>();
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[])>("The given topic name \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: java.lang.String name()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: java.lang.String name()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.NewTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic convertToCreatableTopic()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$1;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateTopicsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$1: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection,org.apache.kafkaesqueesque.clients.admin.CreateTopicsOptions,java.util.Map)>(v, "createTopics", v, v, v, v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopicCollection: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.CreateTopicsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateTopicsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DeleteTopicsResult deleteTopics(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DeleteTopicsOptions)
{
java.util.HashMap v, v;
long v, v;
org.apache.kafkaesqueesque.clients.admin.DeleteTopicsOptions v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.common.utils.Time v;
int v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.common.errors.InvalidTopicException v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$2 v;
org.apache.kafkaesqueesque.clients.admin.DeleteTopicsResult v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DeleteTopicsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean topicNameIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
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[])>("The given topic name \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$2;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteTopicsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$2: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.List,java.util.Map)>(v, "deleteTopics", v, v, v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.DeleteTopicsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteTopicsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ListTopicsResult listTopics(org.apache.kafkaesqueesque.clients.admin.ListTopicsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.clients.admin.ListTopicsOptions v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$3 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
org.apache.kafkaesqueesque.clients.admin.ListTopicsResult v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ListTopicsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$3;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListTopicsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$3: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.ListTopicsOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "listTopics", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ListTopicsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListTopicsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeTopicsResult describeTopics(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DescribeTopicsOptions)
{
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.DescribeTopicsResult v;
int v;
org.apache.kafkaesqueesque.clients.admin.DescribeTopicsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.common.errors.InvalidTopicException v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$4 v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeTopicsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean topicNameIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
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[])>("The given topic name \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$4;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeTopicsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$4: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.ArrayList,org.apache.kafkaesqueesque.clients.admin.DescribeTopicsOptions,java.util.Map)>(v, "describeTopics", v, v, v, v, v);
v = virtualinvoke v.<java.util.ArrayList: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.DescribeTopicsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeTopicsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeClusterResult describeCluster(org.apache.kafkaesqueesque.clients.admin.DescribeClusterOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.clients.admin.DescribeClusterResult v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$5 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
org.apache.kafkaesqueesque.clients.admin.DescribeClusterOptions v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeClusterOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$5;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeClusterOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$5: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.DescribeClusterOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "listNodes", v, v, v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DescribeClusterResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeClusterResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture,org.apache.kafkaesqueesque.common.KafkaFuture,org.apache.kafkaesqueesque.common.KafkaFuture,org.apache.kafkaesqueesque.common.KafkaFuture)>(v, v, v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult describeAcls(org.apache.kafkaesqueesque.common.acl.AclBindingFilter, org.apache.kafkaesqueesque.clients.admin.DescribeAclsOptions)
{
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.acl.AclBindingFilter v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult v, v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.common.errors.InvalidRequestException v;
org.apache.kafkaesqueesque.clients.admin.DescribeAclsOptions v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$6 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.acl.AclBindingFilter;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeAclsOptions;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.acl.AclBindingFilter: boolean isUnknown()>();
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.errors.InvalidRequestException;
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidRequestException: void <init>(java.lang.String)>("The AclBindingFilter must not contain UNKNOWN elements.");
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
v = new org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$6;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeAclsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$6: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.acl.AclBindingFilter,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "describeAcls", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeAclsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.CreateAclsResult createAcls(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.CreateAclsOptions)
{
org.apache.kafkaesqueesque.common.message.CreateAclsRequestData$AclCreation v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.acl.AclBindingFilter v;
java.util.ArrayList v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.admin.CreateAclsOptions v;
org.apache.kafkaesqueesque.common.errors.InvalidRequestException v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.common.message.CreateAclsRequestData v, v;
org.apache.kafkaesqueesque.clients.admin.CreateAclsResult v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$7 v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.CreateAclsOptions;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.acl.AclBinding: org.apache.kafkaesqueesque.common.acl.AclBindingFilter toFilter()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.acl.AclBindingFilter: java.lang.String findIndefiniteField()>();
if v != null goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.CreateAclsRequest: org.apache.kafkaesqueesque.common.message.CreateAclsRequestData$AclCreation aclCreation(org.apache.kafkaesqueesque.common.acl.AclBinding)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.errors.InvalidRequestException;
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[])>("Invalid ACL creation: \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidRequestException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.message.CreateAclsRequestData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateAclsRequestData: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateAclsRequestData: org.apache.kafkaesqueesque.common.message.CreateAclsRequestData setCreations(java.util.List)>(v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$7;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateAclsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$7: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.message.CreateAclsRequestData,java.util.List,java.util.Map)>(v, "createAcls", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.CreateAclsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateAclsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DeleteAclsResult deleteAcls(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DeleteAclsOptions)
{
org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData$DeleteAclsFilter v;
org.apache.kafkaesqueesque.clients.admin.DeleteAclsResult v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
java.util.ArrayList v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.admin.DeleteAclsOptions v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$8 v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DeleteAclsOptions;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.DeleteAclsRequest: org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData$DeleteAclsFilter deleteAclsFilter(org.apache.kafkaesqueesque.common.acl.AclBindingFilter)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData: org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData setFilters(java.util.List)>(v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$8;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteAclsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$8: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.message.DeleteAclsRequestData,java.util.List,java.util.Map)>(v, "deleteAcls", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DeleteAclsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteAclsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeConfigsResult describeConfigs(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions)
{
org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions v;
java.lang.Integer v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$10 v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v, v;
java.util.Collection v;
java.util.Set v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$9 v;
java.util.HashMap v, v, v;
long v, v, v;
org.apache.kafkaesqueesque.clients.admin.DescribeConfigsResult v;
java.util.ArrayList v, v;
int v, v, v;
java.lang.String v;
java.util.Iterator v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean dependsOnSpecificNode(org.apache.kafkaesqueesque.common.config.ConfigResource)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$9;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$9: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Collection,org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions,java.util.Map)>(v, "describeConfigs", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: java.lang.String name()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$10;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$10: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.config.ConfigResource,org.apache.kafkaesqueesque.clients.admin.DescribeConfigsOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "describeBrokerConfigs", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
v = new org.apache.kafkaesqueesque.clients.admin.DescribeConfigsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeConfigsResult: void <init>(java.util.Map)>(v);
return v;
}
private java.util.List configSynonyms(org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigEntry)
{
org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource v;
java.util.Collection v, v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigEntry v;
int v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSynonym v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigEntry;
v = new java.util.ArrayList;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigEntry: java.util.Collection synonyms()>();
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigEntry: java.util.Collection synonyms()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSynonym;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSynonym: java.lang.String name()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSynonym: java.lang.String value()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSynonym: org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource source()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource configSource(org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSynonym: void <init>(java.lang.String,java.lang.String,org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource configSource(org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource)
{
org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource v;
org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource v;
java.lang.IllegalArgumentException v;
int[] v;
int v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource;
v = <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$35: int[] $SwitchMap$org$apache$kafka$common$requests$DescribeConfigsResponse$ConfigSource>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
default: goto label;
};
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource DYNAMIC_TOPIC_CONFIG>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource DYNAMIC_BROKER_CONFIG>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource DYNAMIC_DEFAULT_BROKER_CONFIG>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource STATIC_BROKER_CONFIG>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource DYNAMIC_BROKER_LOGGER_CONFIG>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource: org.apache.kafkaesqueesque.clients.admin.ConfigEntry$ConfigSource DEFAULT_CONFIG>;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.requests.DescribeConfigsResponse$ConfigSource)>(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[])>("Unexpected config source \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult alterConfigs(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions)
{
java.util.HashMap v, v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult v;
java.util.Map v, v, v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
boolean v, v, v;
java.util.Iterator v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean dependsOnSpecificNode(org.apache.kafkaesqueesque.common.config.ConfigResource)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: java.lang.String name()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map alterConfigs(java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Collection,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, v, v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
goto label;
label:
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map alterConfigs(java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Collection,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, v, v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult: void <init>(java.util.Map)>(v);
return v;
}
private java.util.Map alterConfigs(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions, java.util.Collection, org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)
{
org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$Config v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$11 v;
boolean v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v, v;
java.util.Collection v, v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$ConfigEntry v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.Config: java.util.Collection entries()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$ConfigEntry;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ConfigEntry: java.lang.String name()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ConfigEntry: java.lang.String value()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$ConfigEntry: void <init>(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$Config;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AlterConfigsRequest$Config: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$11;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$11: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Map)>(v, "alterConfigs", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult incrementalAlterConfigs(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions)
{
java.util.HashMap v, v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult v;
java.util.Map v, v, v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
boolean v, v, v;
java.util.Iterator v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean dependsOnSpecificNode(org.apache.kafkaesqueesque.common.config.ConfigResource)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: java.lang.String name()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map incrementalAlterConfigs(java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Collection,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, v, v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
goto label;
label:
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map incrementalAlterConfigs(java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Collection,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, v, v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigsResult: void <init>(java.util.Map)>(v);
return v;
}
private java.util.Map incrementalAlterConfigs(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions, java.util.Collection, org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider)
{
java.util.HashMap v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$12 v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$12;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$12: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Collection,java.util.Map,org.apache.kafkaesqueesque.clients.admin.AlterConfigsOptions,java.util.Map)>(v, "incrementalAlterConfigs", v, v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return v;
}
private org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData toIncrementalAlterConfigsRequestData(java.util.Collection, java.util.Map, boolean)
{
org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData v;
org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig v, v, v, v;
org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection v;
byte v, v;
org.apache.kafkaesqueesque.clients.admin.AlterConfigOp$OpType v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource v, v, v;
org.apache.kafkaesqueesque.common.config.ConfigResource$Type v;
boolean v, v, v;
java.util.Iterator v, v;
org.apache.kafkaesqueesque.clients.admin.ConfigEntry v, v;
java.util.Collection v;
org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResourceCollection v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: java.util.Map;
v := @parameter: boolean;
v = new org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData setValidateOnly(boolean)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigOp: org.apache.kafkaesqueesque.clients.admin.ConfigEntry configEntry()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ConfigEntry: java.lang.String name()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig setName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigOp: org.apache.kafkaesqueesque.clients.admin.ConfigEntry configEntry()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ConfigEntry: java.lang.String value()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig setValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigOp: org.apache.kafkaesqueesque.clients.admin.AlterConfigOp$OpType opType()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConfigOp$OpType: byte id()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfig setConfigOperation(byte)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: org.apache.kafkaesqueesque.common.config.ConfigResource$Type type()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource$Type: byte id()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource setResourceType(byte)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: java.lang.String name()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource setResourceName(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource setConfigs(org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData: org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResourceCollection resources()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResourceCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
goto label;
label:
return v;
}
public org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsResult alterReplicaLogDirs(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsOptions)
{
java.lang.Integer v, v, v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$13 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Set v, v, v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsOptions v;
java.util.HashMap v, v, v, v;
long v, v;
org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsResult v;
org.apache.kafkaesqueesque.common.TopicPartition v;
int v, v, v, v;
java.lang.String v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Map: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: int brokerId()>();
v = new org.apache.kafkaesqueesque.common.TopicPartition;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: int partition()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$13;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$13: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Map,int,java.util.Map)>(v, "alterReplicaLogDirs", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterReplicaLogDirsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsResult describeLogDirs(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$14 v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
int v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsOptions v;
java.util.Iterator v, v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsResult v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$14;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$14: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Map,java.lang.Integer)>(v, "describeLogDirs", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeLogDirsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult describeReplicaLogDirs(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$15 v;
java.lang.Integer v, v;
org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Collection v;
java.util.Set v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.util.HashMap v, v, v, v;
long v, v;
java.util.function.Function v;
org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult$ReplicaLogDirInfo v;
org.apache.kafkaesqueesque.common.TopicPartition v;
int v, v, v, v;
java.lang.String v;
java.util.Iterator v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: int brokerId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_describeReplicaLogDirs_2__507: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
v = new org.apache.kafkaesqueesque.common.TopicPartition;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartitionReplica: int partition()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult$ReplicaLogDirInfo;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult$ReplicaLogDirInfo: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$15;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$15: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Set,int,java.util.Map,java.util.Map)>(v, "describeReplicaLogDirs", v, v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeReplicaLogDirsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.CreatePartitionsResult createPartitions(java.util.Map, org.apache.kafkaesqueesque.clients.admin.CreatePartitionsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$16 v;
java.util.HashMap v, v;
long v, v;
org.apache.kafkaesqueesque.clients.admin.CreatePartitionsOptions v;
java.lang.Integer v;
java.util.function.Function v;
org.apache.kafkaesqueesque.clients.admin.CreatePartitionsResult v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.util.stream.Collector v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Set v, v;
java.util.stream.Stream v, v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.CreatePartitionsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Map: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_createPartitions_4__508: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$16;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreatePartitionsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$16: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.List,org.apache.kafkaesqueesque.clients.admin.CreatePartitionsOptions,java.util.Map)>(v, "createPartitions", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.CreatePartitionsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreatePartitionsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DeleteRecordsResult deleteRecords(java.util.Map, org.apache.kafkaesqueesque.clients.admin.DeleteRecordsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$17 v;
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
java.util.HashSet v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
boolean v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v, v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.admin.DeleteRecordsResult v;
org.apache.kafkaesqueesque.clients.admin.DeleteRecordsOptions v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DeleteRecordsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Map: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteRecordsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$17;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$17: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Set,java.util.Map,java.util.Map,long)>(v, "topicsMetadata", v, v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DeleteRecordsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteRecordsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenResult createDelegationToken(org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions)
{
org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$18 v;
long v, v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenResult v;
java.util.List v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions: java.util.List renewers()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers: org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers setPrincipalName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal: java.lang.String getPrincipalType()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers: org.apache.kafkaesqueesque.common.message.CreateDelegationTokenRequestData$CreatableRenewers setPrincipalType(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$18;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$18: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.List,org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "createDelegationToken", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.CreateDelegationTokenResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenResult renewDelegationToken(byte[], org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenOptions)
{
byte[] v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$19 v;
org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenResult v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: byte[];
v := @parameter: org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$19;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$19: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,byte[],org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "renewDelegationToken", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.RenewDelegationTokenResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenResult expireDelegationToken(byte[], org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenOptions)
{
byte[] v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenOptions v;
org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenResult v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$20 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: byte[];
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$20;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$20: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,byte[],org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "expireDelegationToken", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ExpireDelegationTokenResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenResult describeDelegationToken(org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenOptions v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenResult v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$21 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$21;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$21: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenOptions,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "describeDelegationToken", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeDelegationTokenResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
private void rescheduleFindCoordinatorTask(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext, java.util.function.Supplier)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.slf4j.Logger v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: java.util.function.Supplier;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Node {} is no longer the Coordinator. Retrying with new coordinator.", v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void setNode(org.apache.kafkaesqueesque.common.Node)>(null);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return;
}
private void rescheduleMetadataTask(org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext, java.util.function.Supplier)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.slf4j.Logger v;
long v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext v;
java.util.Optional v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext;
v := @parameter: java.util.function.Supplier;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Retrying to fetch metadata.");
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext: void setResponse(java.util.Optional)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getMetadataCall(org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return;
}
private static java.util.Map createFutures(java.util.Collection)
{
java.util.HashSet v;
java.util.stream.Stream v;
java.util.Collection v;
java.lang.Object v;
java.util.stream.Collector v;
java.util.function.Function v, v;
v := @parameter: java.util.Collection;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = virtualinvoke v.<java.util.HashSet: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_createFutures_5__509: java.util.function.Function bootstrap$()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_createFutures_6__510: java.util.function.Function bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsResult describeConsumerGroups(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsOptions)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
java.util.HashMap v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsResult v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
boolean v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v;
java.lang.Object v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsOptions v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsOptions;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map createFutures(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean isCompletedExceptionally()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_describeConsumerGroups_7__511: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DescribeConsumerGroupsResult: void <init>(java.util.Map)>(v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext, java.util.function.Supplier)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$22 v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: java.util.function.Supplier;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$22;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$22: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, "findCoordinator", v, v, v, v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getDescribeConsumerGroupsCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$23 v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$23;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$23: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "describeConsumerGroups", v, v, v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getMetadataCall(org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext, java.util.function.Supplier)
{
org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$24 v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext;
v := @parameter: java.util.function.Supplier;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$24;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$24: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext,java.util.function.Supplier)>(v, "metadata", v, v, v, v);
return v;
}
private java.util.Set validAclOperations(int)
{
java.util.function.Predicate v;
java.util.Set v;
java.util.function.Function v;
java.util.stream.Stream v, v, v;
int v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: int;
if v != -2147483648 goto label;
return null;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.util.Set from32BitField(int)>(v);
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$fromCode__512: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_validAclOperations_8__513: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
private boolean handleGroupRequestError(org.apache.kafkaesqueesque.common.protocol.Errors, org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)
{
org.apache.kafkaesqueesque.common.errors.ApiException v, v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.common.protocol.Errors v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Errors;
v := @parameter: org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v != v goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
throw v;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NONE>;
if v == v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
return 1;
label:
return 0;
}
public org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsResult listConsumerGroups(org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$25 v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
long v, v;
org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsResult v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$25;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$25: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl,long)>(v, "findAllBrokers", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupsResult: void <init>(org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsResult listConsumerGroupOffsets(java.lang.String, org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsResult v;
org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsOptions v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_listConsumerGroupOffsets_9__514: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListConsumerGroupOffsetsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getListConsumerGroupOffsetsCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$26 v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$26;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$26: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "listConsumerGroupOffsets", v, v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsResult deleteConsumerGroups(java.util.Collection, org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsOptions)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
java.util.HashMap v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
boolean v, v;
org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsResult v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsOptions;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.Map createFutures(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean isCompletedExceptionally()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_deleteConsumerGroups_10__515: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupsResult: void <init>(java.util.Map)>(v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getDeleteConsumerGroupsCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$27 v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$27;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$27: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "deleteConsumerGroups", v, v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult deleteConsumerGroupOffsets(java.lang.String, java.util.Set, org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsOptions)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.InvalidGroupIdException v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsOptions v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: java.util.Set;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean groupIdIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.InvalidGroupIdException;
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[])>("The given group id \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidGroupIdException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
v = new org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture,java.util.Set)>(v, v);
return v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_deleteConsumerGroupOffsets_11__516: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.Set)>(v, v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.DeleteConsumerGroupOffsetsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture,java.util.Set)>(v, v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getDeleteConsumerGroupOffsetsCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext, java.util.Set)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$28 v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
java.util.Set v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: java.util.Set;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$28;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$28: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Set,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "deleteConsumerGroupOffsets", v, v, v, v);
return v;
}
public java.util.Map metrics()
{
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: java.util.Map metrics()>();
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ElectLeadersResult electLeaders(org.apache.kafkaesqueesque.common.ElectionType, java.util.Set, org.apache.kafkaesqueesque.clients.admin.ElectLeadersOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$29 v;
org.apache.kafkaesqueesque.common.ElectionType v;
java.util.Set v;
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
org.apache.kafkaesqueesque.clients.admin.ElectLeadersOptions v;
org.apache.kafkaesqueesque.clients.admin.ElectLeadersResult v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.ElectionType;
v := @parameter: java.util.Set;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ElectLeadersOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$29;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ElectLeadersOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$29: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.common.ElectionType,java.util.Set,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "electLeaders", v, v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ElectLeadersResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ElectLeadersResult: void <init>(org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsResult alterPartitionReassignments(java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsOptions)
{
org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsOptions v;
java.lang.Integer v, v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
boolean v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.InvalidTopicException v, v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
java.util.HashMap v, v;
long v, v;
org.apache.kafkaesqueesque.common.TopicPartition v;
int v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$30 v;
java.lang.String v, v, v, v;
java.util.Iterator v;
org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsResult v;
java.util.TreeMap v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsOptions;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: int partition()>();
v = new org.apache.kafkaesqueesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean topicNameIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
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[])>("The given topic name \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: int partition()>();
if v >= 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: int partition()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("The given partition index \u is not valid.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$30;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$30: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Map,java.util.Map)>(v, "alterPartitionReassignments", v, v, v, v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
label:
v = new org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterPartitionReassignmentsResult: void <init>(java.util.Map)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Optional, org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsOptions)
{
long v, v;
java.lang.Integer v;
org.apache.kafkaesqueesque.common.utils.Time v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$31 v;
org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult v, v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsOptions v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.errors.InvalidTopicException v, v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.util.Optional v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Optional;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: int partition()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: boolean topicNameIsUnrepresentable(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
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[])>("The given topic name \'\u0001\' cannot be represented in a request.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
if v >= 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("The given partition index \u is not valid.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidTopicException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean isCompletedExceptionally()>();
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$31;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ControllerNodeProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$31: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Optional,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, "listPartitionReassignments", v, v, v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListPartitionReassignmentsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
private void handleNotControllerError(org.apache.kafkaesqueesque.common.protocol.Errors) throws org.apache.kafkaesqueesque.common.errors.ApiException
{
org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager v, v;
org.apache.kafkaesqueesque.common.errors.ApiException v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Errors;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager metadataManager>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager: void clearController()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager metadataManager>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.AdminMetadataManager: void requestUpdate()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
throw v;
}
private boolean dependsOnSpecificNode(org.apache.kafkaesqueesque.common.config.ConfigResource)
{
org.apache.kafkaesqueesque.common.config.ConfigResource v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.common.config.ConfigResource$Type v, v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.common.config.ConfigResource;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: org.apache.kafkaesqueesque.common.config.ConfigResource$Type type()>();
v = <org.apache.kafkaesqueesque.common.config.ConfigResource$Type: org.apache.kafkaesqueesque.common.config.ConfigResource$Type BROKER>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: boolean isDefault()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.ConfigResource: org.apache.kafkaesqueesque.common.config.ConfigResource$Type type()>();
v = <org.apache.kafkaesqueesque.common.config.ConfigResource$Type: org.apache.kafkaesqueesque.common.config.ConfigResource$Type BROKER_LOGGER>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupResult removeMembersFromConsumerGroup(java.lang.String, org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupOptions)
{
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupResult v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupOptions v;
java.util.Set v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupOptions;
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_removeMembersFromConsumerGroup_12__517: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupResult;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupOptions: java.util.Set members()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.RemoveMembersFromConsumerGroupResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture,java.util.Set)>(v, v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getRemoveMembersFromGroupCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$32 v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$32;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$32: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "leaveGroup", v, v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsResult alterConsumerGroupOffsets(java.lang.String, java.util.Map, org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsOptions)
{
org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsResult v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsOptions v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsOptions;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: void <init>(java.lang.String,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_alterConsumerGroupOffsets_13__518: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.Map)>(v, v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getFindCoordinatorCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsResult;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.AlterConsumerGroupOffsetsResult: void <init>(org.apache.kafkaesqueesque.common.KafkaFuture)>(v);
return v;
}
private org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getAlterConsumerGroupOffsetsCall(org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext, java.util.Map)
{
org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext v;
long v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.util.Map v;
int v;
java.util.Optional v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$33 v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$33;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$33: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,java.util.Map,org.apache.kafkaesqueesque.clients.admin.internals.ConsumerGroupOperationContext)>(v, "commitOffsets", v, v, v, v);
return v;
}
public org.apache.kafkaesqueesque.clients.admin.ListOffsetsResult listOffsets(java.util.Map, org.apache.kafkaesqueesque.clients.admin.ListOffsetsOptions)
{
java.util.HashMap v, v;
long v, v;
java.lang.Integer v;
java.util.function.Supplier v;
java.util.HashSet v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
int v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.clients.admin.ListOffsetsOptions v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call v;
boolean v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesqueesque.clients.admin.ListOffsetsResult v;
org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.ListOffsetsOptions;
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Map: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListOffsetsOptions: java.lang.Integer timeoutMs()>();
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: long calcDeadlineMs(long,java.lang.Integer)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext: void <init>(java.util.Collection,org.apache.kafkaesqueesque.clients.admin.AbstractOptions,long,java.util.Map)>(v, v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_listOffsets_14__519: java.util.function.Supplier bootstrap$(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext,java.util.Map,java.util.Map)>(v, v, v, v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call getMetadataCall(org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext,java.util.function.Supplier)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void call(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
v = new org.apache.kafkaesqueesque.clients.admin.ListOffsetsResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.ListOffsetsResult: void <init>(java.util.Map)>(v);
return v;
}
private java.util.List getListOffsetsCalls(org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext, java.util.Map, java.util.Map)
{
org.apache.kafkaesqueesque.common.Node v;
java.util.Map v, v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
boolean v, v, v, v, v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext v;
java.util.Optional v, v;
org.apache.kafkaesqueesque.common.requests.ListOffsetRequest$PartitionData v;
org.apache.kafkaesqueesque.clients.admin.OffsetSpec v;
java.util.HashMap v;
long v, v;
java.util.function.Function v;
java.util.function.Supplier v;
java.util.ArrayList v;
int v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$34 v;
java.util.Iterator v, v;
org.apache.kafkaesqueesque.common.errors.ApiException v, v;
org.apache.kafkaesqueesque.common.Cluster v;
org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext;
v := @parameter: java.util.Map;
v := @parameter: java.util.Map;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext: java.util.Optional response()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_getListOffsetsCalls_15__520: java.util.function.Supplier bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElseThrow(java.util.function.Supplier)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = v instanceof org.apache.kafkaesqueesque.clients.admin.OffsetSpec$TimestampSpec;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.OffsetSpec$TimestampSpec: long timestamp()>();
goto label;
label:
v = v instanceof org.apache.kafkaesqueesque.clients.admin.OffsetSpec$EarliestSpec;
if v == 0 goto label;
v = -2L;
goto label;
label:
v = -1L;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.MetadataResponse: java.util.Map errors()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.MetadataResponse: org.apache.kafkaesqueesque.common.Cluster cluster()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Cluster: org.apache.kafkaesqueesque.common.Node leaderFor(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v == null goto label;
v = staticinvoke <org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$lambda_getListOffsetsCalls_16__521: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
v = new org.apache.kafkaesqueesque.common.requests.ListOffsetRequest$PartitionData;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ListOffsetRequest$PartitionData: void <init>(long,java.util.Optional)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors LEADER_NOT_AVAILABLE>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.MetadataResponse: java.util.Map errors()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.Node: int id()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$34;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("listOffsets on broker \u0001");
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext: long deadline()>();
v = new org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider;
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$ConstantNodeIdProvider: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,int)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$34: void <init>(org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient$NodeProvider,org.apache.kafkaesqueesque.clients.admin.internals.MetadataOperationContext,java.util.Map,java.util.Map,java.util.Map,java.util.Map$Entry)>(v, v, v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
static java.lang.Throwable getSubLevelError(java.util.Map, java.lang.Object, java.lang.String)
{
java.util.Map v;
org.apache.kafkaesqueesque.common.errors.ApiException v;
java.lang.Object v, v;
java.lang.String v;
java.lang.IllegalArgumentException v;
boolean v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
return v;
label:
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
return v;
}
static void <clinit>()
{
java.util.concurrent.atomic.AtomicInteger v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(1);
<org.apache.kafkaesqueesque.clients.admin.KafkaAdminClient: java.util.concurrent.atomic.AtomicInteger ADMIN_CLIENT_ID_SEQUENCE> = v;
return;
}
}