public class org.apache.kafkaesqueesque.common.requests.FetchRequest extends org.apache.kafkaesqueesque.common.requests.AbstractRequest
{
public static final int CONSUMER_REPLICA_ID;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Str RACK_ID;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V0;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V0;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V0;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V1;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V2;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V3;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V4;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V5;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V5;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V5;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V6;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field$Array FORGOTTEN_PARTITIONS;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field FORGOTTEN_TOPIC_DATA_V7;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V7;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V8;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_PARTITION_V9;
private static final org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_TOPIC_V9;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V9;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V10;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V11;
public static final int DEFAULT_RESPONSE_MAX_BYTES;
public static final long INVALID_LOG_START_OFFSET;
private final int replicaId;
private final int maxWait;
private final int minBytes;
private final int maxBytes;
private final org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel;
private final java.util.Map fetchData;
private final java.util.List toForget;
private final org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata;
private final java.lang.String rackId;
public static org.apache.kafkaesqueesque.common.protocol.types.Schema[] schemaVersions()
{
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[12];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V1>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V2>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V3>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V4>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V5>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V6>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V7>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V8>;
v[8] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V9>;
v[9] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V10>;
v[10] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V11>;
v[11] = v;
return v;
}
private void <init>(short, int, int, int, int, java.util.Map, org.apache.kafkaesqueesque.common.IsolationLevel, java.util.List, org.apache.kafkaesqueesque.common.requests.FetchMetadata, java.lang.String)
{
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.IsolationLevel v;
java.util.List v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
short v;
org.apache.kafkaesqueesque.common.requests.FetchMetadata v;
java.util.Map v;
int v, v, v, v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v := @parameter: short;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.common.IsolationLevel;
v := @parameter: java.util.List;
v := @parameter: org.apache.kafkaesqueesque.common.requests.FetchMetadata;
v := @parameter: java.lang.String;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys FETCH>;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractRequest: void <init>(org.apache.kafkaesqueesque.common.protocol.ApiKeys,short)>(v, v);
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int replicaId> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxWait> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int minBytes> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxBytes> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.List toForget> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata> = v;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.lang.String rackId> = v;
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
java.lang.Integer v, v, v, v, v, v, v, v;
byte v;
java.lang.Long v, v;
java.util.Map v;
java.lang.Object[] v, v, v, v;
long v, v;
java.util.ArrayList v;
java.util.LinkedHashMap v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Array v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v, v, v;
org.apache.kafkaesqueesque.common.IsolationLevel v, v;
java.lang.Byte v;
boolean v, v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray v, v, v, v;
java.util.List v;
java.util.Optional v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.TopicPartition v, v;
org.apache.kafkaesqueesque.common.requests.FetchMetadata v;
org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
java.lang.Object v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys FETCH>;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractRequest: void <init>(org.apache.kafkaesqueesque.common.protocol.ApiKeys,short)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int replicaId> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxWait> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int minBytes> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, 2147483647);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxBytes> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesqueesque.common.protocol.types.Field)>(v);
if v == 0 goto label;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Byte get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Byte: byte byteValue()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.IsolationLevel: org.apache.kafkaesqueesque.common.IsolationLevel forId(byte)>(v);
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel> = v;
goto label;
label:
v = <org.apache.kafkaesqueesque.common.IsolationLevel: org.apache.kafkaesqueesque.common.IsolationLevel READ_UNCOMMITTED>;
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel> = v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.List toForget> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
if v == 0 goto label;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesqueesque.common.protocol.types.Field$Str)>(v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Array FORGOTTEN_PARTITIONS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesque.common.protocol.types.Field$Array)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.List toForget>;
v = new org.apache.kafkaesqueesque.common.TopicPartition;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = new org.apache.kafkaesqueesque.common.requests.FetchMetadata;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, 0);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH>;
v = (int) -1;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchMetadata: void <init>(int,int)>(v, v);
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesqueesque.common.protocol.types.Field$Str)>(v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getOrElse(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,long)>(v, -1L);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.RequestUtils: java.util.Optional getLeaderEpoch(org.apache.kafkaesqueesque.common.protocol.types.Struct,org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v, v);
v = new org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData: void <init>(long,long,int,java.util.Optional)>(v, v, v, v);
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData>;
v = new org.apache.kafkaesqueesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Str RACK_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String getOrElse(org.apache.kafkaesqueesque.common.protocol.types.Field$Str,java.lang.String)>(v, "");
v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.lang.String rackId> = v;
return;
}
public org.apache.kafkaesqueesque.common.requests.AbstractResponse getErrorResponse(int, java.lang.Throwable)
{
java.lang.Throwable v;
java.util.LinkedHashMap v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
org.apache.kafkaesqueesque.common.requests.FetchMetadata v;
java.util.Map v;
int v, v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
org.apache.kafkaesqueesque.common.requests.FetchResponse$PartitionData v;
boolean v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesqueesque.common.record.MemoryRecords v;
org.apache.kafkaesqueesque.common.requests.FetchResponse v;
java.util.Optional v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v := @parameter: int;
v := @parameter: java.lang.Throwable;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors forException(java.lang.Throwable)>(v);
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.requests.FetchResponse$PartitionData;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = <org.apache.kafkaesqueesque.common.record.MemoryRecords: org.apache.kafkaesqueesque.common.record.MemoryRecords EMPTY>;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchResponse$PartitionData: void <init>(org.apache.kafkaesqueesque.common.protocol.Errors,long,long,long,java.util.Optional,java.util.List,org.apache.kafkaesqueesque.common.record.BaseRecords)>(v, -1L, -1L, -1L, v, null, v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchMetadata: int sessionId()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchResponse: void <init>(org.apache.kafkaesqueesque.common.protocol.Errors,java.util.LinkedHashMap,int,int)>(v, v, v, v);
return v;
}
public int replicaId()
{
int v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int replicaId>;
return v;
}
public int maxWait()
{
int v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxWait>;
return v;
}
public int minBytes()
{
int v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int minBytes>;
return v;
}
public int maxBytes()
{
int v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxBytes>;
return v;
}
public java.util.Map fetchData()
{
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData>;
return v;
}
public java.util.List toForget()
{
java.util.List v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.List toForget>;
return v;
}
public boolean isFromFollower()
{
int v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int replicaId>;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel()
{
org.apache.kafkaesqueesque.common.IsolationLevel v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel>;
return v;
}
public org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata()
{
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
org.apache.kafkaesqueesque.common.requests.FetchMetadata v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata>;
return v;
}
public java.lang.String rackId()
{
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.lang.String rackId>;
return v;
}
public static org.apache.kafkaesqueesque.common.requests.FetchRequest parse(java.nio.ByteBuffer, short)
{
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: short;
v = new org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys FETCH>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.types.Struct parseRequest(short,java.nio.ByteBuffer)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
return v;
}
protected org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct()
{
java.lang.Integer v, v, v, v;
byte v;
java.lang.Long v;
java.util.Map v;
java.util.Set v, v, v;
java.lang.Object[] v, v, v, v;
long v, v;
java.util.ArrayList v, v, v;
java.util.LinkedHashMap v;
org.apache.kafkaesqueesque.common.requests.FetchRequest v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Array v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v, v, v;
org.apache.kafkaesqueesque.common.IsolationLevel v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Byte v;
boolean v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray v, v, v, v, v, v, v;
java.util.List v, v;
java.util.Optional v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v, v, v, v;
java.util.HashMap v;
java.util.function.Function v;
org.apache.kafkaesqueesque.common.requests.FetchMetadata v, v;
int v, v, v, v, v, v, v, v, v;
java.util.Iterator v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v;
java.lang.Object v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.FetchRequest;
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys FETCH>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: short version()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.types.Schema requestSchema(short)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.Map fetchData>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.FetchRequest$TopicAndPartitionData: java.util.List batchByTopic(java.util.Iterator)>(v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int replicaId>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxWait>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int minBytes>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: int maxBytes>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.IsolationLevel isolationLevel>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.IsolationLevel: byte id()>();
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchMetadata: int sessionId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.requests.FetchMetadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.FetchMetadata: int epoch()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$TopicAndPartitionData: java.lang.String topic>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Str,java.lang.String)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$TopicAndPartitionData: java.util.LinkedHashMap partitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData: long fetchOffset>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,long)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData: int maxBytes>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData: long logStartOffset>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest$PartitionData: java.util.Optional currentLeaderEpoch>;
staticinvoke <org.apache.kafkaesqueesque.common.requests.RequestUtils: void setLeaderEpochIfExists(org.apache.kafkaesqueesque.common.protocol.types.Struct,org.apache.kafkaesqueesque.common.protocol.types.Field$Int,java.util.Optional)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray,java.lang.Object[])>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray,java.lang.Object[])>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
if v == 0 goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.util.List toForget>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: java.lang.String topic()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.FetchRequest$lambda_toStruct_0__382: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: int partition()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Str,java.lang.String)>(v, v);
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Array FORGOTTEN_PARTITIONS>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Array,java.lang.Object[])>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray,java.lang.Object[])>(v, v);
label:
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Str RACK_ID>;
v = v.<org.apache.kafkaesqueesque.common.requests.FetchRequest: java.lang.String rackId>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Array v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: void <init>(java.lang.String,java.lang.String)>("topics", "Topics to fetch in the order provided.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: void <init>(java.lang.String,java.lang.String)>("forgotten_topics_data", "Topics to remove from the fetch session.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("max_bytes", "Maximum bytes to accumulate in the response. Note that this is not an absolute maximum, if the first message in the first non-empty partition of the fetch is larger than this value, the message will still be returned to ensure that progress can be made.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int8: void <init>(java.lang.String,java.lang.String)>("isolation_level", "This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("session_id", "The fetch session ID");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("session_epoch", "The fetch session epoch");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Str;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Str: void <init>(java.lang.String,java.lang.String)>("rack_id", "The consumer\'s rack id");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Str RACK_ID> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: void <init>(java.lang.String,java.lang.String)>("partitions", "Partitions to fetch.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("replica_id", "Broker id of the follower. For normal consumers, use -1.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("fetch_offset", "Message offset.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("partition_max_bytes", "Maximum bytes to fetch.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("max_wait_time", "Maximum time in ms to wait for the response.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("min_bytes", "Minimum bytes to accumulate in the response.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("log_start_offset", "Earliest available offset of the follower replica. The field is only used when request is sent by follower. ");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES>;
v[2] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V0> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V0>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V0> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V0>;
v[3] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V0> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V0>;
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V1> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V1>;
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V2> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V0>;
v[4] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V3> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[6];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V0>;
v[5] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V4> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES>;
v[3] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V5> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field PARTITIONS_V5>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V5> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[6];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V5>;
v[5] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V5> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V5>;
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V6> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field$Array;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$Array: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partitions", v, "Partitions to remove from the fetch session.");
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Array FORGOTTEN_PARTITIONS> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray FORGOTTEN_TOPICS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Array FORGOTTEN_PARTITIONS>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FORGOTTEN_TOPIC_DATA_V7> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[9];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field TOPICS_V5>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FORGOTTEN_TOPIC_DATA_V7>;
v[8] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V7> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V7>;
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V8> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int FETCH_OFFSET>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_MAX_BYTES>;
v[4] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_PARTITION_V9> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_PARTITION_V9>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_TOPIC_V9> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[9];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_TOPIC_V9>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FORGOTTEN_TOPIC_DATA_V7>;
v[8] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V9> = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V9>;
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V10> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[10];
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_WAIT_TIME>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MIN_BYTES>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int MAX_BYTES>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_ID>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Int SESSION_EPOCH>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FETCH_REQUEST_TOPIC_V9>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field FORGOTTEN_TOPIC_DATA_V7>;
v[8] = v;
v = <org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Field$Str RACK_ID>;
v[9] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.FetchRequest: org.apache.kafkaesqueesque.common.protocol.types.Schema FETCH_REQUEST_V11> = v;
return;
}
}