public class org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher extends java.lang.Object implements java.io.Closeable { private final org.slf4j.Logger log; private final org.apache.kafkaesqueesque.common.utils.LogContext logContext; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient client; private final org.apache.kafkaesqueesque.common.utils.Time time; private final int minBytes; private final int maxBytes; private final int maxWaitMs; private final int fetchSize; private final long retryBackoffMs; private final long requestTimeoutMs; private final int maxPollRecords; private final boolean checkCrcs; private final java.lang.String clientRackId; private final org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata metadata; private final org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$FetchManagerMetrics sensors; private final org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions; private final java.util.concurrent.ConcurrentLinkedQueue completedFetches; private final org.apache.kafkaesqueesque.common.record.BufferSupplier decompressionBufferSupplier; private final org.apache.kafkaesqueesque.common.serialization.Deserializer keyDeserializer; private final org.apache.kafkaesqueesque.common.serialization.Deserializer valueDeserializer; private final org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel; private final java.util.Map sessionHandlers; private final java.util.concurrent.atomic.AtomicReference cachedListOffsetsException; private final java.util.concurrent.atomic.AtomicReference cachedOffsetForLeaderException; private final org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient offsetsForLeaderEpochClient; private final java.util.Set nodesWithPendingFetchRequests; private final org.apache.kafkaesqueesque.clients.ApiVersions apiVersions; private org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$CompletedFetch nextInLineFetch; public void (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) { org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; org.apache.kafkaesqueesque.common.IsolationLevel v; org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry v; java.util.HashMap v; long v, v; java.util.concurrent.atomic.AtomicReference v, v; java.util.HashSet v; org.apache.kafkaesqueesque.common.metrics.Metrics v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.common.serialization.Deserializer v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v; int v, v, v, v, v; java.lang.String v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.apache.kafkaesqueesque.clients.ApiVersions v; boolean v; org.apache.kafkaesqueesque.common.record.BufferSupplier v; org.slf4j.Logger v; org.apache.kafkaesqueesque.common.utils.LogContext v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; java.util.concurrent.ConcurrentLinkedQueue v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: boolean; v := @parameter: java.lang.String; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.common.serialization.Deserializer; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState; v := @parameter: org.apache.kafkaesqueesque.common.metrics.Metrics; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry; v := @parameter: org.apache.kafkaesqueesque.common.utils.Time; v := @parameter: long; v := @parameter: long; v := @parameter: org.apache.kafkaesqueesque.common.IsolationLevel; v := @parameter: org.apache.kafkaesqueesque.clients.ApiVersions; specialinvoke v.()>(); v = staticinvoke (); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v. = null; v = virtualinvoke v.(class "Lorg/apache/kafkaesqueesque/clients/consumer/internals/Fetcher;"); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v = new java.util.concurrent.ConcurrentLinkedQueue; specialinvoke v.()>(); v. = v; v = new org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$FetchManagerMetrics; specialinvoke v.(org.apache.kafkaesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesque.clients.consumer.internals.FetcherMetricsRegistry)>(v, v); v. = v; v. = v; v. = v; v. = v; v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient; specialinvoke v.(org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; return; } protected boolean hasCompletedFetches() { org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; boolean v, v; java.util.concurrent.ConcurrentLinkedQueue v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean hasAvailableFetches() { java.util.stream.Stream v; java.util.function.Predicate v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; boolean v; java.util.concurrent.ConcurrentLinkedQueue v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); return v; } public synchronized int sendFetches() { org.apache.kafkaesqueesque.common.IsolationLevel v, v; java.lang.Integer v; org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v; java.util.Map v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v; boolean v, v; java.util.Set v, v; java.util.List v; java.lang.Object[] v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$1 v; org.apache.kafkaesqueesque.common.requests.FetchMetadata v; int v, v, v, v, v; java.lang.String v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.kafkaesqueesque.common.requests.FetchRequest$Builder v, v, v, v, v, v; java.lang.Object v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = v.; specialinvoke v.(v); v = specialinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Sending {} {} to broker {}", v); label: v = v.; v = virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = new org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$1; specialinvoke v.(org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher,org.apache.kafkaesqueesque.common.Node,org.apache.kafkaesqueesque.clients.FetchSessionHandler$FetchRequestData)>(v, v, v); virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); return v; } public java.util.Map getAllTopicMetadata(org.apache.kafkaesqueesque.common.utils.Timer) { java.util.Map v; org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = staticinvoke (); v = virtualinvoke v.(v, v); return v; } public java.util.Map getTopicMetadata(org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder, org.apache.kafkaesqueesque.common.utils.Timer) { org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v; java.util.Map v, v; org.apache.kafkaesqueesque.common.protocol.Errors v, v; org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.requests.AbstractResponse v; java.util.Set v, v, v; org.apache.kafkaesqueesque.common.errors.InvalidTopicException v; org.apache.kafkaesqueesque.common.errors.TopicAuthorizationException v; java.util.List v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; java.util.HashMap v; long v; java.lang.String v, v; org.slf4j.Logger v; java.util.Iterator v, v; org.apache.kafkaesqueesque.common.errors.ApiException v, v; java.lang.RuntimeException v; org.apache.kafkaesqueesque.common.Cluster v; org.apache.kafkaesqueesque.common.KafkaException v; java.lang.Object v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); return v; label: v = specialinvoke v.(v); v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.TopicAuthorizationException; specialinvoke v.(java.util.Set)>(v); throw v; label: v = 0; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; interfaceinvoke v.("Topic metadata fetch included errors: {}", v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; if v != v goto label; v = new org.apache.kafkaesqueesque.common.errors.InvalidTopicException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Topic \'\u0001\' is invalid"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; if v == v goto label; v = virtualinvoke v.(); v = v instanceof org.apache.kafkaesqueesque.common.errors.RetriableException; if v == 0 goto label; v = 1; goto label; label: v = new org.apache.kafkaesqueesque.common.KafkaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected error fetching metadata for topic \u0001"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: if v != 0 goto label; v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v, v); goto label; label: return v; label: v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; specialinvoke v.(java.lang.String)>("Timeout expired while fetching topic metadata"); throw v; } private org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture sendMetadataRequest(org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder) { org.apache.kafkaesqueesque.common.Node v; org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v, v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v, v; org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.requests.MetadataRequest$Builder; v = v.; v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (); return v; label: v = v.; v = virtualinvoke v.(v, v); return v; } private java.lang.Long offsetResetStrategyTimestamp(org.apache.kafkaesqueesque.common.TopicPartition) { org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v, v, v; org.apache.kafkaesqueesque.common.TopicPartition v; java.lang.Long 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.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v = v.; v = virtualinvoke v.(v); v = ; if v != v goto label; v = staticinvoke (-2L); return v; label: v = ; if v != v goto label; v = staticinvoke (-1L); return v; label: return null; } private org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy timestampToOffsetResetStrategy(long) { org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v, v; byte v, v; long v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: long; v = v cmp -2L; if v != 0 goto label; v = ; return v; label: v = v cmp -1L; if v != 0 goto label; v = ; return v; label: return null; } public void resetOffsetsIfNeeded() { java.util.Iterator v; java.util.Set v; java.util.HashMap v; long v; java.util.concurrent.atomic.AtomicReference v; org.apache.kafkaesqueesque.common.utils.Time v; java.lang.Long v; java.lang.Object v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; boolean v, v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = virtualinvoke v.(null); if v == null goto label; throw v; label: v = v.; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; return; label: v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); if v == null goto label; interfaceinvoke v.(v, v); goto label; label: specialinvoke v.(v); return; } public void validateOffsetsIfNeeded() { long v; java.util.concurrent.atomic.AtomicReference v; java.util.function.Function v, v; org.apache.kafkaesqueesque.common.utils.Time v; java.util.stream.Collector v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v; java.util.Set v, v; java.util.function.Consumer v; java.util.stream.Stream v; java.lang.Object v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = v.; v = virtualinvoke v.(null); if v == null goto label; throw v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); specialinvoke v.(v); return; } public java.util.Map offsetsForTimes(java.util.Map, org.apache.kafkaesqueesque.common.utils.Timer) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v, v, v; java.util.HashMap v; long v, v; java.lang.Long v; java.util.Map v, v; int v; boolean v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult v; java.util.Iterator v, v; java.util.Set v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.OffsetAndTimestamp v; java.util.Optional v; java.lang.Object v, 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.internals.Fetcher; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = v.; v = interfaceinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); label: v = specialinvoke v.(v, v, 1); v = v.; v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, null); goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.kafkaesqueesque.clients.consumer.OffsetAndTimestamp; v = v.; v = v.; v = virtualinvoke v.(); v = v.; specialinvoke v.(long,long,java.util.Optional)>(v, v, v); virtualinvoke v.(v, v); goto label; label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } private org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult fetchOffsetsByTimes(java.util.Map, org.apache.kafkaesqueesque.common.utils.Timer, boolean) { java.util.HashMap v; long v; org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v; java.util.Map v, v, v; java.lang.String v; boolean v, v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult v; java.util.Set v, v; java.lang.RuntimeException v; java.lang.Object v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerNetworkClient v, v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; org.apache.kafkaesqueesque.common.errors.TimeoutException v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v := @parameter: boolean; v = new org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult; specialinvoke v.()>(); v = interfaceinvoke v.(); if v == 0 goto label; return v; label: v = new java.util.HashMap; specialinvoke v.(java.util.Map)>(v); label: v = specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = v.; interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); throw v; label: v = interfaceinvoke v.(); if v == 0 goto label; return v; label: v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; label: v = new org.apache.kafkaesqueesque.common.errors.TimeoutException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to get offsets by times in \u0001ms"); specialinvoke v.(java.lang.String)>(v); throw v; } public java.util.Map beginningOffsets(java.util.Collection, org.apache.kafkaesqueesque.common.utils.Timer) { java.util.Collection 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.internals.Fetcher; v := @parameter: java.util.Collection; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = specialinvoke v.(v, -2L, v); return v; } public java.util.Map endOffsets(java.util.Collection, org.apache.kafkaesqueesque.common.utils.Timer) { java.util.Collection 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.internals.Fetcher; v := @parameter: java.util.Collection; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = specialinvoke v.(v, -1L, v); return v; } private java.util.Map beginningOrEndOffset(java.util.Collection, long, org.apache.kafkaesqueesque.common.utils.Timer) { java.lang.Throwable v; org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v, v, v; long v; java.util.function.Function v, v, v, v; java.util.Map v; java.util.stream.Collector v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult v; java.util.Collection v; java.util.Set v, v; java.util.stream.Stream v, v, v; java.lang.Object v, v; org.apache.kafkaesqueesque.common.utils.Timer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: java.util.Collection; v := @parameter: long; v := @parameter: org.apache.kafkaesqueesque.common.utils.Timer; v = v.; v = specialinvoke v.(v); virtualinvoke v.(v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v, 0); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v); v = interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public java.util.Map fetchedRecords() { org.apache.kafkaesqueesque.common.requests.FetchResponse$PartitionData v; boolean v, v, v, v, v, v; java.lang.Exception v; java.util.List v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$CompletedFetch v, v, v, v, v, v, v, v; java.util.concurrent.ConcurrentLinkedQueue v, v, v, v, v, v; java.lang.Throwable v; java.util.HashMap v; java.util.ArrayList v; org.apache.kafkaesqueesque.common.TopicPartition v, v, v; int v, v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; org.apache.kafkaesqueesque.common.record.BaseRecords v, v; org.slf4j.Logger v; org.apache.kafkaesqueesque.common.KafkaException v; java.lang.Object v, v; java.util.ArrayDeque v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.ArrayDeque; specialinvoke v.()>(); v = v.; label: if v <= 0 goto label; v = v.; if v == null goto label; v = v.; v = v.; if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = specialinvoke v.(); if v == 0 goto label; label: v = specialinvoke v.(v); v. = v; label: goto label; label: v := @caughtexception; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: v = v.; virtualinvoke v.(); label: throw v; label: v. = v; label: v = v.; virtualinvoke v.(); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = v.; v = v.; interfaceinvoke v.("Skipping fetching records for assigned partition {} because it is paused", v); v = v.; interfaceinvoke v.(v); v. = null; goto label; label: v = v.; v = specialinvoke v.(v, v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = interfaceinvoke v.(v); if v != null goto label; interfaceinvoke v.(v, v); goto label; label: v = new java.util.ArrayList; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v + v; specialinvoke v.(int)>(v); interfaceinvoke v.(v); interfaceinvoke v.(v); interfaceinvoke v.(v, v); label: v = interfaceinvoke v.(); v = v - v; goto label; label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = interfaceinvoke v.(); if v == 0 goto label; throw v; label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v); throw v; label: return v; catch java.lang.Exception from label to label with label; catch org.apache.kafkaesqueesque.common.KafkaException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private java.util.List fetchRecords(org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$CompletedFetch, int) { org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch v; org.apache.kafkaesqueesque.common.IsolationLevel v; byte v, v; java.lang.Long v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v, v; boolean v, v; java.util.List v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$CompletedFetch v; java.util.Optional v; java.lang.Object[] v, v; long v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.TopicPartition v, v, v, v, v, v, v, v, v, v, v, v, v; int v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$CompletedFetch; v := @parameter: int; v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = v.; interfaceinvoke v.("Not returning fetched records for partition {} since it is no longer assigned", v); goto label; label: v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = v.; interfaceinvoke v.("Not returning fetched records for assigned partition {} since it is no longer fetchable", v); goto label; label: v = v.; v = v.; v = virtualinvoke v.(v); v = v.; v = v.; v = v cmp v; if v != 0 goto label; v = specialinvoke v.(v); v = v.; v = v.; v = v cmp v; if v <= 0 goto label; v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition; v = v.; v = v.; v = v.; specialinvoke v.(long,java.util.Optional,org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v); v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v = v.; v[1] = v; v[2] = v; interfaceinvoke v.("Returning fetched records at offset {} for assigned partition {} and update position to {}", v); v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(v, v); label: v = v.; v = v.; v = virtualinvoke v.(v); if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(v, v); label: return v; label: v = v.; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v[2] = v; interfaceinvoke v.("Ignoring fetched records for {} at offset {} since the current position is {}", v); label: v = v.; v = v.; interfaceinvoke v.("Draining fetched records for partition {}", v); specialinvoke v.(); v = staticinvoke (); return v; } private void resetOffsetIfNeeded(org.apache.kafkaesqueesque.common.TopicPartition, org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy, org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetData) { org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v; org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch v; org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetData v; long v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v; java.util.function.Consumer v; org.apache.kafkaesqueesque.common.TopicPartition v; java.util.Optional 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.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy; v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$ListOffsetData; v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition; v = v.; v = v.; v = v.; v = virtualinvoke v.(v); specialinvoke v.(long,java.util.Optional,org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v); v = v.; v = staticinvoke (v, v); virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v, v, v); return; } private void resetOffsetsAsync(java.util.Map) { long v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$2 v; java.util.HashSet v; org.apache.kafkaesqueesque.common.utils.Time v; org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v; java.util.Map v, v; org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v; boolean v; java.util.Iterator v; java.util.Set v, v; java.lang.Object v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: java.util.Map; v = new java.util.HashSet; specialinvoke v.()>(); v = specialinvoke v.(v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; v = v + v; virtualinvoke v.(v, v); v = specialinvoke v.(v, v, 0); v = new org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$2; specialinvoke v.(org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher,java.util.Map)>(v, v); virtualinvoke v.(v); goto label; label: return; } private boolean hasUsableOffsetForLeaderEpochVersion(org.apache.kafkaesqueesque.clients.NodeApiVersions) { org.apache.kafkaesqueesque.common.protocol.ApiKeys v; short v; org.apache.kafkaesqueesque.clients.NodeApiVersions v; org.apache.kafkaesqueesque.clients.ApiVersion v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; boolean v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: org.apache.kafkaesqueesque.clients.NodeApiVersions; v = ; v = virtualinvoke v.(v); if v != null goto label; return 0; label: v = v.; v = staticinvoke (v); return v; } private void validateOffsetsAsync(java.util.Map) { java.util.Map v, v; java.util.function.BiConsumer v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: java.util.Map; v = specialinvoke v.(v); v = staticinvoke (v, v); interfaceinvoke v.(v); return; } private org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture sendListOffsetsRequests(java.util.Map, boolean) { java.util.HashMap v; org.apache.kafkaesqueesque.clients.StaleMetadataException v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$4 v; java.util.HashSet v; java.util.concurrent.atomic.AtomicInteger v; org.apache.kafkaesqueesque.clients.consumer.internals.RequestFuture v, v, v; java.util.Map v, v; int v; boolean v, v, v; java.util.Iterator v; java.util.Set v; java.lang.Object v, v, v; org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v; v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher; v := @parameter: java.util.Map; v := @parameter: boolean; v = new java.util.HashSet; specialinvoke v.