public class org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer extends java.lang.Object implements org.apache.kafkaesqueesque.clients.consumer.Consumer { private static final java.lang.String CLIENT_ID_METRIC_TAG; private static final long NO_CURRENT_THREAD; private static final java.util.concurrent.atomic.AtomicInteger CONSUMER_CLIENT_ID_SEQUENCE; private static final java.lang.String JMX_PREFIX; static final long DEFAULT_CLOSE_TIMEOUT_MS; final org.apache.kafkaesqueesque.common.metrics.Metrics metrics; final org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics kafkaConsumerMetrics; private org.slf4j.Logger log; private final java.lang.String clientId; private final java.util.Optional groupId; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator coordinator; private final org.apache.kafkaesqueesque.common.serialization.Deserializer keyDeserializer; private final org.apache.kafkaesqueesque.common.serialization.Deserializer valueDeserializer; private final org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher fetcher; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors interceptors; private final org.apache.kafkaesqueesque.common.utils.Time time; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient client; private final org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata metadata; private final long retryBackoffMs; private final long requestTimeoutMs; private final int defaultApiTimeoutMs; private volatile boolean closed; private java.util.List assignors; private final java.util.concurrent.atomic.AtomicLong currentThread; private final java.util.concurrent.atomic.AtomicInteger refcount; private boolean cachedSubscriptionHashAllFetchPositions; public void (java.util.Map) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Map v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; specialinvoke v.(java.util.Map,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.common.serialization.Deserializer)>(v, null, null); return; } public void (java.util.Map, org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.common.serialization.Deserializer) { org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; java.util.Map v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v = new org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig; v = staticinvoke (v, v, v); specialinvoke v.(java.util.Map)>(v); specialinvoke v.(org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.common.serialization.Deserializer)>(v, v, v); return; } public void (java.util.Properties) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Properties v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Properties; specialinvoke v.(java.util.Properties,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.common.serialization.Deserializer)>(v, null, null); return; } public void (java.util.Properties, org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.common.serialization.Deserializer) { org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Properties v, v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Properties; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v = new org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig; v = staticinvoke (v, v, v); specialinvoke v.(java.util.Properties)>(v); specialinvoke v.(org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.common.serialization.Deserializer)>(v, v, v); return; } private void (org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig, org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.common.serialization.Deserializer) { java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v, v, v, v, v; java.lang.Long v, v, v, v, v; java.util.Map v, v, v, v, v; org.apache.kafkaesqueesque.common.errors.InvalidConfigurationException v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v, v, v, v, v, v; long v, v, v, v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicLong v; org.apache.kafkaesqueesque.common.network.ChannelBuilder v; java.util.List[] v; java.util.concurrent.atomic.AtomicInteger v; java.util.Locale v, v; org.apache.kafkaesqueesque.clients.GroupRebalanceConfig v; org.apache.kafkaesqueesque.clients.ClientDnsLookup v; org.apache.kafkaesqueesque.common.metrics.Sensor v; int v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Boolean v, v, v, v; org.apache.kafkaesqueesque.clients.ApiVersions v; org.slf4j.Logger v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; java.lang.Class v; java.lang.Object v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry v; org.apache.kafkaesqueesque.common.utils.Time v, v, v, v, v, v, v, v, v; java.util.Set v; org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics v; java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v, v; org.apache.kafkaesqueesque.common.utils.LogContext v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; org.apache.kafkaesqueesque.common.IsolationLevel v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v; org.apache.kafkaesqueesque.clients.NetworkClient v; org.apache.kafkaesqueesque.clients.GroupRebalanceConfig$ProtocolType v; java.util.List v, v, v, v, v, v, v; java.util.Optional v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.network.Selector v; org.apache.kafkaesqueesque.common.metrics.Metrics v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.common.KafkaException v; org.apache.kafkaesqueesque.common.internals.ClusterResourceListeners v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; specialinvoke v.()>(); v. = 0; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(-1L); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; label: v = new org.apache.kafkaesqueesque.clients.GroupRebalanceConfig; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.config.AbstractConfig,org.apache.kafkaesqueesque.clients.GroupRebalanceConfig$ProtocolType)>(v, v); v = v.; v = staticinvoke (v); v. = v; v = virtualinvoke v.("client.id"); v = staticinvoke (v, v); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.utils.LogContext; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.("null"); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("[Consumer instanceId=\u, clientId=\u, groupId=\u] "); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = new org.apache.kafkaesqueesque.common.utils.LogContext; v = v.; v = v.; v = virtualinvoke v.("null"); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("[Consumer clientId=\u, groupId=\u] "); specialinvoke v.(java.lang.String)>(v); v = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v. = v; v = virtualinvoke v.("enable.auto.commit"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.("enable.auto.commit"); if v != 0 goto label; v = 0; goto label; label: if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.InvalidConfigurationException; specialinvoke v.(java.lang.String)>("enable.auto.commit cannot be set to true when default group id (null) is used."); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("Support for using the empty group id by consumers is deprecated and will be removed in the next major release."); label: v = v.; interfaceinvoke v.("Initializing the Kafka consumer"); v = virtualinvoke v.("request.timeout.ms"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("default.api.timeout.ms"); v = virtualinvoke v.(); v. = v; v = ; v. = v; v = v.; v = v.; v = staticinvoke (v, v, v); v. = v; v = virtualinvoke v.("retry.backoff.ms"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("client.id", v); v = new org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig; specialinvoke v.(java.util.Map,boolean)>(v, 0); v = virtualinvoke v.("interceptor.classes", class "Lorg/apache/kafkaesqueesque/clients/consumer/ConsumerInterceptor;"); v = new org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors; specialinvoke v.(java.util.List)>(v); v. = v; if v != null goto label; v = virtualinvoke v.("key.deserializer", class "Lorg/apache/kafkaesqueesque/common/serialization/Deserializer;"); v. = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, 1); goto label; label: virtualinvoke v.("key.deserializer"); v. = v; label: if v != null goto label; v = virtualinvoke v.("value.deserializer", class "Lorg/apache/kafkaesqueesque/common/serialization/Deserializer;"); v. = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, 0); goto label; label: virtualinvoke v.("value.deserializer"); v. = v; label: v = virtualinvoke v.("auto.offset.reset"); v = ; v = virtualinvoke v.(v); v = staticinvoke (v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState; specialinvoke v.(org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy)>(v, v); v. = v; v = newarray (java.util.List)[2]; v = v.; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = specialinvoke v.(v, v, v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata; v = v.; v = virtualinvoke v.("metadata.max.age.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("exclude.internal.topics"); v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.("allow.auto.create.topics"); v = virtualinvoke v.(); v = v.; specialinvoke v.(long,long,boolean,boolean,org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState,org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.common.internals.ClusterResourceListeners)>(v, v, v, v, v, v, v); v. = v; v = virtualinvoke v.("bootstrap.servers"); v = virtualinvoke v.("client.dns.lookup"); v = staticinvoke (v, v); v = v.; virtualinvoke v.(v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry; v = staticinvoke ("client-id"); specialinvoke v.(java.util.Set,java.lang.String)>(v, "consumer"); v = v.; v = staticinvoke (v, v, v); v = virtualinvoke v.("isolation.level"); v = ; v = virtualinvoke v.(v); v = staticinvoke (v); v = v.; v = staticinvoke (v, v); v = virtualinvoke v.("heartbeat.interval.ms"); v = virtualinvoke v.(); v = new org.apache.kafkaesqueesque.clients.ApiVersions; specialinvoke v.()>(); v = new org.apache.kafkaesqueesque.clients.NetworkClient; v = new org.apache.kafkaesqueesque.common.network.Selector; v = virtualinvoke v.("connections.max.idle.ms"); v = virtualinvoke v.(); v = v.; v = v.; specialinvoke v.(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, "consumer", v, v); v = v.; v = v.; v = virtualinvoke v.("reconnect.backoff.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("reconnect.backoff.max.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("send.buffer.bytes"); v = virtualinvoke v.(); v = virtualinvoke v.("receive.buffer.bytes"); v = virtualinvoke v.(); v = virtualinvoke v.("request.timeout.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("client.dns.lookup"); v = staticinvoke (v); v = v.; specialinvoke v.(org.apache.kafkaesqueesque.common.network.Selectable,org.apache.kafkaesqueesque.clients.Metadata,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.metrics.Sensor,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, 100, v, v, v, v, v, v, v, 1, v, v, v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient; v = v.; v = v.; v = v.; v = virtualinvoke v.("request.timeout.ms"); v = virtualinvoke v.(); specialinvoke v.(org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.clients.KafkaClient,org.apache.kafkaesqueesque.clients.Metadata,org.apache.kafkaesqueesque.common.utils.Time,long,int,int)>(v, v, v, v, v, v, v); v. = v; v = virtualinvoke v.("partition.assignment.strategy"); v = virtualinvoke v.(); v = staticinvoke (v, v); v. = v; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = null; goto label; label: v = new org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.("auto.commit.interval.ms"); v = virtualinvoke v.(); v = v.; specialinvoke v.(org.apache.kafkaesqueesque.clients.GroupRebalanceConfig,org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient,java.util.List,org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata,org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState,org.apache.kafkaesqueesque.common.metrics.Metrics,java.lang.String,org.apache.kafkaesqueesque.common.utils.Time,boolean,int,org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors)>(v, v, v, v, v, v, v, "consumer", v, v, v, v); label: v. = v; v = new org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = virtualinvoke v.("fetch.min.bytes"); v = virtualinvoke v.(); v = virtualinvoke v.("fetch.max.bytes"); v = virtualinvoke v.(); v = virtualinvoke v.("fetch.max.wait.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("max.partition.fetch.bytes"); v = virtualinvoke v.(); v = virtualinvoke v.("max.poll.records"); v = virtualinvoke v.(); v = virtualinvoke v.("check.crcs"); v = virtualinvoke v.(); v = virtualinvoke v.("client.rack"); v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient,int,int,int,int,int,boolean,java.lang.String,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.common.serialization.Deserializer,org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata,org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState,org.apache.kafkaesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry,org.apache.kafkaesqueesque.common.utils.Time,long,long,org.apache.kafkaesqueesque.common.IsolationLevel,org.apache.kafkaesqueesque.clients.ApiVersions)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v); v. = v; v = new org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics; v = v.; specialinvoke v.(org.apache.kafkaesqueesque.common.metrics.Metrics,java.lang.String)>(v, "consumer"); v. = v; virtualinvoke v.(); v = v.; v = v.; v = v.; v = interfaceinvoke v.(); staticinvoke ("kafka.consumer", v, v, v); v = v.; interfaceinvoke v.("Kafka consumer initialized"); label: goto label; label: v := @caughtexception; v = v.; if v == null goto label; specialinvoke v.(0L, 1); label: v = new org.apache.kafkaesqueesque.common.KafkaException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failed to construct kafka consumer", v); throw v; label: return; catch java.lang.Throwable from label to label with label; } void (org.apache.kafkaesqueesque.common.utils.LogContext, java.lang.String, org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator, org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher, org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors, org.apache.kafkaesqueesque.common.utils.Time, org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient, org.apache.kafkaesqueesque.common.metrics.Metrics, org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState, org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata, long, long, int, java.util.List, java.lang.String) { org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; long v, v; org.apache.kafkaesqueesque.common.metrics.Metrics v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; java.util.concurrent.atomic.AtomicInteger v; int v; java.lang.String v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.slf4j.Logger v; org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics v; org.apache.kafkaesqueesque.common.utils.LogContext v; java.util.concurrent.atomic.AtomicLong v; java.util.List v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; java.util.Optional v; java.lang.Class v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext; v := @parameter: java.lang.String; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors; v := @parameter: org.apache.kafkaesqueesque.common.utils.Time; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient; v := @parameter: org.apache.kafkaesqueesque.common.metrics.Metrics; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata; v := @parameter: long; v := @parameter: long; v := @parameter: int; v := @parameter: java.util.List; v := @parameter: java.lang.String; specialinvoke v.()>(); v. = 0; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(-1L); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(v); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v = staticinvoke (v); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v = staticinvoke (v); v. = v; v = new org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics; specialinvoke v.(org.apache.kafkaesqueesque.common.metrics.Metrics,java.lang.String)>(v, "consumer"); v. = v; return; } private static java.lang.String buildClientId(java.lang.String, org.apache.kafkaesqueesque.clients.GroupRebalanceConfig) { java.util.function.Supplier v; java.util.concurrent.atomic.AtomicInteger v; int v; java.util.Optional v; java.lang.Object v; java.lang.String v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.GroupRebalanceConfig v; boolean v, v; v := @parameter: java.lang.String; v := @parameter: org.apache.kafkaesqueesque.clients.GroupRebalanceConfig; v = virtualinvoke v.(); if v != 0 goto label; return v; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("consumer-\u0001-\u0001"); return v; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("consumer-\u0001"); return v; } private static org.apache.kafkaesqueesque.common.metrics.Metrics buildMetrics(org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig, org.apache.kafkaesqueesque.common.utils.Time, java.lang.String) { org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig v; long v; java.lang.Integer v; org.apache.kafkaesqueesque.common.metrics.Metrics v; org.apache.kafkaesqueesque.common.utils.Time v; java.lang.Long v; java.util.Map v, v; int v; java.lang.String v, v; org.apache.kafkaesqueesque.common.metrics.MetricConfig v, v, v, v, v; org.apache.kafkaesqueesque.common.metrics.Sensor$RecordingLevel v; org.apache.kafkaesqueesque.common.metrics.JmxReporter v; java.util.concurrent.TimeUnit v; java.util.List v; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerConfig; v := @parameter: org.apache.kafkaesqueesque.common.utils.Time; v := @parameter: java.lang.String; v = staticinvoke ("client-id", v); v = new org.apache.kafkaesqueesque.common.metrics.MetricConfig; specialinvoke v.()>(); v = virtualinvoke v.("metrics.num.samples"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("metrics.sample.window.ms"); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v, v); v = virtualinvoke v.("metrics.recording.level"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = staticinvoke ("client.id", v); v = virtualinvoke v.("metric.reporters", class "Lorg/apache/kafkaesqueesque/common/metrics/MetricsReporter;", v); v = new org.apache.kafkaesqueesque.common.metrics.JmxReporter; specialinvoke v.(java.lang.String)>("kafka.consumer"); interfaceinvoke v.(v); v = new org.apache.kafkaesqueesque.common.metrics.Metrics; specialinvoke v.(org.apache.kafkaesqueesque.common.metrics.MetricConfig,java.util.List,org.apache.kafkaesqueesque.common.utils.Time)>(v, v, v); return v; } public java.util.Set assignment() { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Set v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Set subscription() { java.lang.Throwable v; java.util.HashSet v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Set v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; specialinvoke v.(); label: v = new java.util.HashSet; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public void subscribe(java.util.Collection, org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; java.util.HashSet v; java.lang.String v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener v; java.lang.IllegalArgumentException v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener; specialinvoke v.(); label: specialinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Topic collection to subscribe to cannot be null"); throw v; label: v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Topic collection to subscribe to cannot contain null or empty topic"); throw v; label: specialinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; v = staticinvoke (v, ", "); interfaceinvoke v.("Subscribed to topic(s): {}", v); v = v.; v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(v, v); if v == 0 goto label; v = v.; virtualinvoke v.(); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void subscribe(java.util.Collection) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener v; java.util.Collection v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v = new org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void subscribe(java.util.regex.Pattern, org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v, v; org.slf4j.Logger v; org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; org.apache.kafkaesqueesque.common.Cluster v; java.util.regex.Pattern v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.regex.Pattern; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener; specialinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Topic pattern to subscribe to cannot be null"); throw v; label: specialinvoke v.(); label: specialinvoke v.(); v = v.; interfaceinvoke v.("Subscribed to pattern: \'{}\'", v); v = v.; virtualinvoke v.(v, v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void subscribe(java.util.regex.Pattern) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.regex.Pattern v; org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.regex.Pattern; v = new org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void unsubscribe() { java.lang.Throwable v; org.slf4j.Logger v; java.util.Set v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; specialinvoke v.(); label: v = v.; v = staticinvoke (); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.("the consumer unsubscribed from all topics"); label: v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.("Unsubscribed all topics or patterns and assigned partitions"); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void assign(java.util.Collection) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; long v; java.util.HashSet v; org.apache.kafkaesqueesque.common.utils.Time v; java.lang.String v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; java.lang.IllegalArgumentException v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; specialinvoke v.(); label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Topic partition collection to assign to cannot be null"); throw v; label: v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = null; label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Topic partitions to assign to cannot have null or empty topic"); throw v; label: v = v.; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); label: v = v.; v = staticinvoke (v, ", "); interfaceinvoke v.("Subscribed to partition(s): {}", v); v = v.; v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(long) { org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; long v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: long; v = v.; v = interfaceinvoke v.(v); v = specialinvoke v.(v, 0); return v; } public org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(java.time.Duration) { org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.time.Duration; v = v.; v = interfaceinvoke v.(v); v = specialinvoke v.(v, 1); return v; } private org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(org.apache.kafkaesqueesque.common.utils.Timer, boolean) { java.lang.IllegalStateException v; org.apache.kafkaesqueesque.common.utils.Time v, v; java.util.Map v; boolean v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords v, v, v; org.apache.kafkaesqueesque.common.utils.Timer v, v, v; java.lang.Throwable v; long v, v, v, v; int v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.slf4j.Logger v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v := @parameter: boolean; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Consumer is not subscribed to any topics or assigned any partitions"); throw v; label: v = v.; virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(0L); virtualinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(9223372036854775807L); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.("Still waiting for metadata"); goto label; label: v = specialinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v > 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; virtualinvoke v.(); label: v = v.; v = new org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords; specialinvoke v.(java.util.Map)>(v); v = virtualinvoke v.(v); label: specialinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (); label: specialinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return v; label: v := @caughtexception; specialinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } boolean updateAssignmentMetadataIfNeeded(org.apache.kafkaesqueesque.common.utils.Timer) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v; org.apache.kafkaesqueesque.common.utils.Timer v; boolean v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; return 0; label: v = specialinvoke v.(v); return v; } private java.util.Map pollForFetches(org.apache.kafkaesqueesque.common.utils.Timer) { org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition v; long v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.utils.Time v; byte v; java.util.Map v, v; boolean v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.common.utils.Timer v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v, v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = v.; if v != null goto label; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); label: v = v; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; return v; label: v = v.; virtualinvoke v.(); v = v.; if v != 0 goto label; v = v.; v = v cmp v; if v <= 0 goto label; v = v.; label: v = v.; v = interfaceinvoke v.(v); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); return v; } public void commitSync() { int v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = staticinvoke (v); virtualinvoke v.(v); return; } public void commitSync(java.time.Duration) { java.lang.Throwable v; long v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; java.time.Duration v; java.util.Map v; java.lang.String v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.time.Duration; specialinvoke v.(); label: specialinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Timeout of \u0001ms expired before successfully committing the current consumed offsets"); specialinvoke v.(java.lang.String)>(v); throw v; label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void commitSync(java.util.Map) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; int v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); return; } public void commitSync(java.util.Map, java.time.Duration) { java.lang.Throwable v; java.util.HashMap v; long v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; java.time.Duration v; java.util.Map v; java.util.function.BiConsumer v; java.lang.String v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v := @parameter: java.time.Duration; specialinvoke v.(); label: specialinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = new java.util.HashMap; specialinvoke v.(java.util.Map)>(v); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Timeout of \u0001ms expired before successfully committing offsets \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void commitAsync() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; virtualinvoke v.(null); return; } public void commitAsync(org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback v; java.util.Map v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } public void commitAsync(java.util.Map, org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback) { java.lang.Throwable v; org.slf4j.Logger v; java.util.HashMap v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback v; java.util.Map v; java.util.function.BiConsumer v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback; specialinvoke v.(); label: specialinvoke v.(); v = v.; interfaceinvoke v.("Committing offsets: {}", v); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = new java.util.HashMap; specialinvoke v.(java.util.Map)>(v); virtualinvoke v.(v, v); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void seek(org.apache.kafkaesqueesque.common.TopicPartition, long) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch v; org.slf4j.Logger v; long v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; byte v; java.lang.Long v; java.util.Optional v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: long; v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("seek offset must not be a negative number"); throw v; label: specialinvoke v.(); label: v = v.; v = staticinvoke (v); interfaceinvoke v.("Seeking to offset {} for partition {}", v, v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition; v = staticinvoke (); v = v.; v = virtualinvoke v.(v); specialinvoke v.(long,java.util.Optional,org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v); v = v.; virtualinvoke v.(v, v); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void seek(org.apache.kafkaesqueesque.common.TopicPartition, org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch v; java.lang.Object[] v; long v, v; org.apache.kafkaesqueesque.common.TopicPartition v; byte v; java.lang.Long v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v; org.slf4j.Logger v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata v; java.util.Optional v, v, v; java.lang.Object v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata; v = virtualinvoke v.(); v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("seek offset must not be a negative number"); throw v; label: specialinvoke v.(); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Seeking to offset {} for partition {} with epoch {}", v); goto label; label: v = v.; v = staticinvoke (v); interfaceinvoke v.("Seeking to offset {} for partition {}", v, v); label: v = v.; v = virtualinvoke v.(v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,java.util.Optional,org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v); specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void seekToBeginning(java.util.Collection) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v; java.util.Collection v, v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; int v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Partitions collection cannot be null"); throw v; label: specialinvoke v.(); label: v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v; label: v = v.; v = ; virtualinvoke v.(v, v); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void seekToEnd(java.util.Collection) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v; java.util.Collection v, v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; int v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Partitions collection cannot be null"); throw v; label: specialinvoke v.(); label: v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v; label: v = v.; v = ; virtualinvoke v.(v, v); label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public long position(org.apache.kafkaesqueesque.common.TopicPartition) { org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; int v; long v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public long position(org.apache.kafkaesqueesque.common.TopicPartition, java.time.Duration) { java.lang.Throwable v; java.lang.IllegalStateException v; long v, v; org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.common.utils.Time v; java.time.Duration v; java.lang.String v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v; boolean v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("You can only check the position for partitions assigned to this consumer."); throw v; label: v = v.; v = interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(v); if v == null goto label; v = v.; label: specialinvoke v.(); return v; label: specialinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Timeout of \u0001ms expired before the position for partition \u could be determined"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesque.common.TopicPartition) { org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; int v; org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesque.common.TopicPartition, java.time.Duration) { org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; java.util.Set v; java.lang.Object v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: java.time.Duration; v = staticinvoke (v); v = virtualinvoke v.(v, v); v = interfaceinvoke v.(v); return v; } public java.util.Map committed(java.util.Set) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; int v; java.util.Set v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Set; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public java.util.Map committed(java.util.Set, java.time.Duration) { java.lang.Throwable v; java.util.Set v; long v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; java.time.Duration v; java.util.Map v; java.util.function.BiConsumer v; java.lang.String v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Set; v := @parameter: java.time.Duration; specialinvoke v.(); label: specialinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); if v != null goto label; v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Timeout of \u0001ms expired before the last committed offset for partitions \u could be determined. Try tuning default.api.timeout.ms larger to relax the threshold."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = staticinvoke (v); interfaceinvoke v.(v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Map metrics() { org.apache.kafkaesqueesque.common.metrics.Metrics v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Map v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); return v; } public java.util.List partitionsFor(java.lang.String) { java.util.List v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; int v; java.lang.String v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.lang.String; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public java.util.List partitionsFor(java.lang.String, java.time.Duration) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v, v; org.apache.kafkaesqueesque.common.utils.Time v; java.time.Duration v; java.util.Map v; org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder v; java.lang.String v; boolean v, v; java.util.List v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.common.Cluster v; java.lang.Object v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.lang.String; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; label: specialinvoke v.(); return v; label: v = v.; v = interfaceinvoke v.(v); v = v.; v = new org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); specialinvoke v.(java.util.List,boolean)>(v, v); v = virtualinvoke v.(v, v); v = interfaceinvoke v.(v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public java.util.Map listTopics() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; int v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); return v; } public java.util.Map listTopics(java.time.Duration) { java.lang.Throwable v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public void pause(java.util.Collection) { java.lang.Throwable v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; specialinvoke v.(); label: v = v.; interfaceinvoke v.("Pausing partitions {}", v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); goto label; label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void resume(java.util.Collection) { java.lang.Throwable v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; specialinvoke v.(); label: v = v.; interfaceinvoke v.("Resuming partitions {}", v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); goto label; label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public java.util.Set paused() { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Set v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Map offsetsForTimes(java.util.Map) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v, v; int v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public java.util.Map offsetsForTimes(java.util.Map, java.time.Duration) { java.lang.Throwable v; long v; org.apache.kafkaesqueesque.common.utils.Time v; byte v; java.time.Duration v; java.util.Map v, v; java.lang.String v; boolean v; java.util.Iterator v; java.util.Set v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.lang.Object v, v, v, v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Map; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("The target time for partition \u is \u. The target time cannot be negative."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Map beginningOffsets(java.util.Collection) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Collection v; java.util.Map v; int v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public java.util.Map beginningOffsets(java.util.Collection, java.time.Duration) { java.lang.Throwable v; java.util.Collection v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Map endOffsets(java.util.Collection) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Collection v; java.util.Map v; long v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } public java.util.Map endOffsets(java.util.Collection, java.time.Duration) { java.lang.Throwable v; java.util.Collection v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; java.util.Map v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.util.Collection; v := @parameter: java.time.Duration; specialinvoke v.(); label: v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v, v); label: specialinvoke v.(); return v; label: v := @caughtexception; specialinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v; org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = virtualinvoke v.(); return v; } public void close() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = staticinvoke (30000L); virtualinvoke v.(v); return; } public void close(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.time.Duration v; long v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; v = virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); return; } public void close(java.time.Duration) { java.lang.Throwable v; long v, v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; byte v; java.time.Duration v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: java.time.Duration; v = virtualinvoke v.(); v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The timeout cannot be negative."); throw v; label: specialinvoke v.(); label: v = v.; if v != 0 goto label; v = virtualinvoke v.(); specialinvoke v.(v, 0); label: v. = 1; specialinvoke v.(); goto label; label: v := @caughtexception; v. = 1; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void wakeup() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; virtualinvoke v.(); return; } private transient org.apache.kafkaesqueesque.common.internals.ClusterResourceListeners configureClusterResourceListeners(org.apache.kafkaesqueesque.common.serialization.Deserializer, org.apache.kafkaesqueesque.common.serialization.Deserializer, java.util.List[]) { java.util.List[] v; java.util.List v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; org.apache.kafkaesqueesque.common.internals.ClusterResourceListeners v; int v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: java.util.List[]; v = new org.apache.kafkaesqueesque.common.internals.ClusterResourceListeners; specialinvoke v.()>(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; virtualinvoke v.(v); v = v + 1; goto label; label: virtualinvoke v.(v); virtualinvoke v.(v); return v; } private void close(long, boolean) { java.lang.Throwable v, v; long v, v, v; java.util.concurrent.atomic.AtomicReference v; org.apache.kafkaesqueesque.common.metrics.Metrics v, v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; java.lang.String v; boolean v, v; org.slf4j.Logger v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.KafkaConsumerMetrics v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v; org.apache.kafkaesqueesque.common.KafkaException v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerInterceptors v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: long; v := @parameter: boolean; v = v.; interfaceinvoke v.("Closing the Kafka consumer"); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); label: v = v.; if v == null goto label; v = v.; v = v.; v = v.; v = staticinvoke (v, v); v = interfaceinvoke v.(v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; virtualinvoke v.(null, v); v = v.; interfaceinvoke v.("Failed to close coordinator", v); label: v = v.; staticinvoke (v, "fetcher", v); v = v.; staticinvoke (v, "consumer interceptors", v); v = v.; staticinvoke (v, "kafka consumer metrics", v); v = v.; staticinvoke (v, "consumer metrics", v); v = v.; staticinvoke (v, "consumer network client", v); v = v.; staticinvoke (v, "consumer key deserializer", v); v = v.; staticinvoke (v, "consumer value deserializer", v); v = v.; v = v.; staticinvoke ("kafka.consumer", v, v); v = v.; interfaceinvoke v.("Kafka consumer has been closed"); v = virtualinvoke v.(); if v == null goto label; if v != 0 goto label; v = v instanceof org.apache.kafkaesqueesque.common.errors.InterruptException; if v == 0 goto label; throw v; label: v = new org.apache.kafkaesqueesque.common.KafkaException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failed to close kafka consumer", v); throw v; label: return; catch java.lang.Throwable from label to label with label; } private boolean updateFetchPositions(org.apache.kafkaesqueesque.common.utils.Timer) { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerCoordinator v, v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v, v; boolean v, v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v. = v; v = v.; if v == 0 goto label; return 1; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); return 1; } private void acquireAndEnsureOpen() { java.lang.IllegalStateException v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; specialinvoke v.(); v = v.; if v == 0 goto label; specialinvoke v.(); v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This consumer has already been closed."); throw v; label: return; } private void acquire() { long v, v; java.util.concurrent.atomic.AtomicLong v, v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; byte v; java.util.concurrent.atomic.AtomicInteger v; java.lang.Thread v; java.util.ConcurrentModificationException v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = staticinvoke (); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = v.; v = virtualinvoke v.(-1L, v); if v != 0 goto label; v = new java.util.ConcurrentModificationException; specialinvoke v.(java.lang.String)>("KafkaConsumer is not safe for multi-threaded access"); throw v; label: v = v.; virtualinvoke v.(); return; } private void release() { java.util.concurrent.atomic.AtomicLong v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.concurrent.atomic.AtomicInteger v; int v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(-1L); label: return; } private void throwIfNoAssignorsConfigured() { java.lang.IllegalStateException v; java.util.List v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Must configure at least one partition assigner class name to partition.assignment.strategy configuration property"); throw v; label: return; } private void maybeThrowInvalidGroupIdException() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.util.Optional v; boolean v; org.apache.kafkaesqueesque.common.errors.InvalidGroupIdException v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.InvalidGroupIdException; specialinvoke v.(java.lang.String)>("To use the group management or offset commit APIs, you must provide a valid group.id in the consumer configuration."); throw v; label: return; } public void updateLastSeenEpochIfNewer(org.apache.kafkaesqueesque.common.TopicPartition, org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata) { java.util.function.Consumer v; org.apache.kafkaesqueesque.common.TopicPartition v; org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata v; java.util.Optional v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v, v); virtualinvoke v.(v); label: return; } java.lang.String getClientId() { org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer v; java.lang.String v; v := @this: org.apache.kafkaesqueesque.clients.consumer.KafkaConsumer; v = v.; return v; } static void () { java.util.concurrent.atomic.AtomicInteger v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(1); = v; return; } }