public class org.apache.kafkaesque.common.requests.FetchResponse extends org.apache.kafkaesque.common.requests.AbstractResponse
{
private static final java.lang.String RESPONSES_KEY_NAME;
private static final java.lang.String PARTITIONS_KEY_NAME;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int PREFERRED_READ_REPLICA;
private static final java.lang.String PARTITION_HEADER_KEY_NAME;
private static final java.lang.String ABORTED_TRANSACTIONS_KEY_NAME;
private static final java.lang.String RECORD_SET_KEY_NAME;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V0;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V0;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V0;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V0;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V1;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V2;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V3;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int PRODUCER_ID;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int FIRST_OFFSET;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_ABORTED_TRANSACTION_V4;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V4;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V5;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V6;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V4;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V5;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V6;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V4;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V5;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V6;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V4;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V5;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V6;
private static final org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V7;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V8;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V9;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V10;
private static final org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V11;
public static final long INVALID_HIGHWATERMARK;
public static final long INVALID_LAST_STABLE_OFFSET;
public static final long INVALID_LOG_START_OFFSET;
public static final int INVALID_PREFERRED_REPLICA_ID;
private final int throttleTimeMs;
private final org.apache.kafkaesque.common.protocol.Errors error;
private final int sessionId;
private final java.util.LinkedHashMap responseData;
public static org.apache.kafkaesque.common.protocol.types.Schema[] schemaVersions()
{
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[12];
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V0>;
v[0] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V1>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V2>;
v[2] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V3>;
v[3] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V4>;
v[4] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V5>;
v[5] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V6>;
v[6] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V7>;
v[7] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V8>;
v[8] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V9>;
v[9] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V10>;
v[10] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V11>;
v[11] = v;
return v;
}
public void <init>(org.apache.kafkaesque.common.protocol.Errors, java.util.LinkedHashMap, int, int)
{
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.protocol.Errors v;
org.apache.kafkaesque.common.requests.FetchResponse v;
int v, v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v := @parameter: java.util.LinkedHashMap;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: void <init>()>();
v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error> = v;
v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData> = v;
v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs> = v;
v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId> = v;
return;
}
public static org.apache.kafkaesque.common.requests.FetchResponse parse(org.apache.kafkaesque.common.protocol.types.Struct)
{
org.apache.kafkaesque.common.protocol.Errors v, v;
java.lang.Integer v, v, v, v, v;
java.lang.Long v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v;
java.lang.Object[] v, v, v;
long v, v, v, v, v;
java.util.ArrayList v, v;
java.util.LinkedHashMap v;
short v, v;
java.lang.String v, v;
org.apache.kafkaesque.common.protocol.types.Field$Str v;
java.lang.IllegalStateException v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v, v;
org.apache.kafkaesque.common.requests.FetchResponse$PartitionData v;
org.apache.kafkaesque.common.record.BaseRecords v;
java.lang.Short v, v;
boolean v, v;
java.util.function.Predicate v, v;
org.apache.kafkaesque.common.requests.FetchResponse v;
org.apache.kafkaesque.common.requests.FetchResponse$AbortedTransaction v;
java.util.Optional v, v;
org.apache.kafkaesque.common.TopicPartition v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
java.lang.Class v;
java.lang.Object v, v, v;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("responses");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesque.common.protocol.types.Field$Str)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("partition_responses");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct getStruct(java.lang.String)>("partition_header");
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int PARTITION_ID>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Short get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v = staticinvoke <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors forCode(short)>(v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, -1L);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, -1L);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PREFERRED_READ_REPLICA>;
v = (int) -1;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,int)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = (int) -1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.util.function.Predicate: java.util.function.Predicate isEqual(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.function.Predicate: java.util.function.Predicate negate()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional filter(java.util.function.Predicate)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.record.BaseRecords getRecords(java.lang.String)>("record_set");
v = v instanceof org.apache.kafkaesque.common.record.MemoryRecords;
if v != 0 goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unknown records type found: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: boolean hasField(java.lang.String)>("aborted_transactions");
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("aborted_transactions");
if v == null goto label;
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PRODUCER_ID>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int FIRST_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = new org.apache.kafkaesque.common.requests.FetchResponse$AbortedTransaction;
specialinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse$AbortedTransaction: void <init>(long,long)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new org.apache.kafkaesque.common.requests.FetchResponse$PartitionData;
specialinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: void <init>(org.apache.kafkaesque.common.protocol.Errors,long,long,long,java.util.Optional,java.util.List,org.apache.kafkaesque.common.record.BaseRecords)>(v, v, v, v, v, v, v);
v = new org.apache.kafkaesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
virtualinvoke v.<java.util.LinkedHashMap: 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 = new org.apache.kafkaesque.common.requests.FetchResponse;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Short getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,short)>(v, 0);
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v = staticinvoke <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors forCode(short)>(v);
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,int)>(v, 0);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesque.common.protocol.types.Field$Int,int)>(v, 0);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: void <init>(org.apache.kafkaesque.common.protocol.Errors,java.util.LinkedHashMap,int,int)>(v, v, v, v);
return v;
}
public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)
{
org.apache.kafkaesque.common.protocol.Errors v;
java.util.Iterator v;
org.apache.kafkaesque.common.requests.FetchResponse v;
java.util.Set v;
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
int v, v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v := @parameter: short;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId>;
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short,int,org.apache.kafkaesque.common.protocol.Errors,java.util.Iterator,int)>(v, v, v, v, v);
return v;
}
protected org.apache.kafkaesque.common.network.Send toSend(java.lang.String, org.apache.kafkaesque.common.requests.ResponseHeader, short)
{
org.apache.kafkaesque.common.record.MultiRecordsSend v;
org.apache.kafkaesque.common.requests.ResponseHeader v;
java.nio.ByteBuffer v;
short v;
int v, v, v, v, v, v;
org.apache.kafkaesque.common.network.ByteBufferSend v;
java.lang.String v;
java.nio.ByteBuffer[] v;
org.apache.kafkaesque.common.requests.FetchResponse v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
java.util.ArrayDeque v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.requests.ResponseHeader;
v := @parameter: short;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ResponseHeader: org.apache.kafkaesque.common.protocol.types.Struct toStruct()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: int sizeOf()>();
v = v + 4;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: int sizeOf()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: int sizeOf()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void writeTo(java.nio.ByteBuffer)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new java.util.ArrayDeque;
specialinvoke v.<java.util.ArrayDeque: void <init>()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs>;
staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: void addResponseData(org.apache.kafkaesque.common.protocol.types.Struct,int,java.lang.String,java.util.Queue)>(v, v, v, v);
v = new org.apache.kafkaesque.common.record.MultiRecordsSend;
specialinvoke v.<org.apache.kafkaesque.common.record.MultiRecordsSend: void <init>(java.lang.String,java.util.Queue)>(v, v);
return v;
}
public org.apache.kafkaesque.common.protocol.Errors error()
{
org.apache.kafkaesque.common.protocol.Errors v;
org.apache.kafkaesque.common.requests.FetchResponse v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error>;
return v;
}
public java.util.LinkedHashMap responseData()
{
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.requests.FetchResponse v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData>;
return v;
}
public int throttleTimeMs()
{
int v;
org.apache.kafkaesque.common.requests.FetchResponse v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs>;
return v;
}
public int sessionId()
{
int v;
org.apache.kafkaesque.common.requests.FetchResponse v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId>;
return v;
}
public java.util.Map errorCounts()
{
org.apache.kafkaesque.common.protocol.Errors v;
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesque.common.requests.FetchResponse v;
java.util.HashMap v;
java.util.LinkedHashMap v;
java.lang.Object v;
boolean v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: org.apache.kafkaesque.common.protocol.Errors error>;
virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: void updateErrorCounts(java.util.Map,org.apache.kafkaesque.common.protocol.Errors)>(v, v);
goto label;
label:
return v;
}
public static org.apache.kafkaesque.common.requests.FetchResponse parse(java.nio.ByteBuffer, short)
{
org.apache.kafkaesque.common.protocol.types.Schema v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
org.apache.kafkaesque.common.requests.FetchResponse v;
org.apache.kafkaesque.common.protocol.ApiKeys v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: short;
v = <org.apache.kafkaesque.common.protocol.ApiKeys: org.apache.kafkaesque.common.protocol.ApiKeys FETCH>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ApiKeys: org.apache.kafkaesque.common.protocol.types.Schema responseSchema(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: org.apache.kafkaesque.common.protocol.types.Struct read(java.nio.ByteBuffer)>(v);
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.requests.FetchResponse parse(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
}
private static void addResponseData(org.apache.kafkaesque.common.protocol.types.Struct, int, java.lang.String, java.util.Queue)
{
java.lang.Object[] v;
java.lang.Integer v;
java.nio.ByteBuffer v, v, v;
short v;
java.lang.Short v;
int v, v, v, v, v, v, v;
org.apache.kafkaesque.common.network.ByteBufferSend v, v, v;
java.lang.String v;
boolean v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v;
java.nio.ByteBuffer[] v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.lang.Object v;
java.util.Queue v;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.util.Queue;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("responses");
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesque.common.protocol.types.Field)>(v);
if v == 0 goto label;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(14);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Short get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putShort(short)>(v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
v = lengthof v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesque.common.protocol.types.Field)>(v);
if v == 0 goto label;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(8);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
v = lengthof v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(4);
v = lengthof v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: void addTopicData(java.lang.String,java.util.Queue,org.apache.kafkaesque.common.protocol.types.Struct)>(v, v, v);
v = v + 1;
goto label;
label:
return;
}
private static void addTopicData(java.lang.String, java.util.Queue, org.apache.kafkaesque.common.protocol.types.Struct)
{
org.apache.kafkaesque.common.protocol.types.Field$Str v;
java.lang.Object[] v;
java.nio.ByteBuffer v;
int v, v, v, v, v;
org.apache.kafkaesque.common.network.ByteBufferSend v;
java.lang.String v, v;
java.nio.ByteBuffer[] v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.lang.Object v;
java.util.Queue v;
v := @parameter: java.lang.String;
v := @parameter: java.util.Queue;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesque.common.protocol.types.Field$Str)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("partition_responses");
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Type$DocumentedType: int sizeOf(java.lang.Object)>(v);
v = v + 4;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Type$DocumentedType: void write(java.nio.ByteBuffer,java.lang.Object)>(v, v);
v = lengthof v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: void addPartitionData(java.lang.String,java.util.Queue,org.apache.kafkaesque.common.protocol.types.Struct)>(v, v, v);
v = v + 1;
goto label;
label:
return;
}
private static void addPartitionData(java.lang.String, java.util.Queue, org.apache.kafkaesque.common.protocol.types.Struct)
{
java.nio.ByteBuffer[] v;
org.apache.kafkaesque.common.record.RecordsSend v;
org.apache.kafkaesque.common.record.BaseRecords v;
long v;
java.nio.ByteBuffer v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
byte v;
int v, v, v;
org.apache.kafkaesque.common.network.ByteBufferSend v;
java.lang.String v;
java.util.Queue v;
v := @parameter: java.lang.String;
v := @parameter: java.util.Queue;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct getStruct(java.lang.String)>("partition_header");
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.record.BaseRecords getRecords(java.lang.String)>("record_set");
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: int sizeOf()>();
v = v + 4;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void writeTo(java.nio.ByteBuffer)>(v);
v = interfaceinvoke v.<org.apache.kafkaesque.common.record.BaseRecords: int sizeInBytes()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
v = new org.apache.kafkaesque.common.network.ByteBufferSend;
v = newarray (java.nio.ByteBuffer)[1];
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.network.ByteBufferSend: void <init>(java.lang.String,java.nio.ByteBuffer[])>(v, v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.kafkaesque.common.record.BaseRecords: org.apache.kafkaesque.common.record.RecordsSend toSend(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.record.RecordsSend: long size()>();
v = v cmp 0L;
if v <= 0 goto label;
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
label:
return;
}
private static org.apache.kafkaesque.common.protocol.types.Struct toStruct(short, int, org.apache.kafkaesque.common.protocol.Errors, java.util.Iterator, int)
{
org.apache.kafkaesque.common.protocol.Errors v, v, v, v;
java.lang.Integer v, v, v;
java.lang.Long v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v;
java.util.Set v;
java.lang.Object[] v, v, v;
long v, v, v, v, v;
java.util.ArrayList v, v, v;
java.util.LinkedHashMap v;
short v, v, v, v;
java.lang.String v;
org.apache.kafkaesque.common.protocol.types.Field$Str v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v, v, v;
org.apache.kafkaesque.common.record.BaseRecords v;
org.apache.kafkaesque.common.protocol.ApiKeys v;
org.apache.kafkaesque.common.protocol.types.Schema v;
java.lang.Short v;
boolean v, v, v, v;
java.util.List v, v, v, v;
java.util.Optional v;
int v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v;
java.util.Iterator v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Struct v, v, v, v, v;
java.lang.Object v, v, v, v, v, v;
v := @parameter: short;
v := @parameter: int;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v := @parameter: java.util.Iterator;
v := @parameter: int;
v = new org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.protocol.ApiKeys: org.apache.kafkaesque.common.protocol.ApiKeys FETCH>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ApiKeys: org.apache.kafkaesque.common.protocol.types.Schema responseSchema(short)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesque.common.protocol.types.Schema)>(v);
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: short code()>();
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchRequest$TopicAndPartitionData: java.util.List batchByTopic(java.util.Iterator)>(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 = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct instance(java.lang.String)>("responses");
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = v.<org.apache.kafkaesque.common.requests.FetchRequest$TopicAndPartitionData: java.lang.String topic>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.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.kafkaesque.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 = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: org.apache.kafkaesque.common.protocol.Errors error>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: short code()>();
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors KAFKA_STORAGE_ERROR>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: short code()>();
if v != v goto label;
if v > 5 goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors NOT_LEADER_FOR_PARTITION>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: short code()>();
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct instance(java.lang.String)>("partition_responses");
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct instance(java.lang.String)>("partition_header");
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.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.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,short)>(v, v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: long highWatermark>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesque.common.protocol.types.Field)>(v);
if v == 0 goto label;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: long lastStableOffset>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, v);
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: java.util.List abortedTransactions>;
if v != null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("aborted_transactions", null);
goto label;
label:
v = new java.util.ArrayList;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: java.util.List abortedTransactions>;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: java.util.List abortedTransactions>;
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.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct instance(java.lang.String)>("aborted_transactions");
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PRODUCER_ID>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$AbortedTransaction: long producerId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int FIRST_OFFSET>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$AbortedTransaction: long firstOffset>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(org.apache.kafkaesque.common.protocol.types.Field$Int,long)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("aborted_transactions", v);
label:
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: long logStartOffset>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PREFERRED_READ_REPLICA>;
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: java.util.Optional preferredReadReplica>;
v = (int) -1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesque.common.protocol.types.Field,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_header", v);
v = v.<org.apache.kafkaesque.common.requests.FetchResponse$PartitionData: org.apache.kafkaesque.common.record.BaseRecords records>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("record_set", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_responses", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("responses", v);
return v;
}
public static int sizeOf(short, java.util.Iterator)
{
org.apache.kafkaesque.common.protocol.types.Struct v;
org.apache.kafkaesque.common.protocol.Errors v;
short v;
java.util.Iterator v;
int v, v;
v := @parameter: short;
v := @parameter: java.util.Iterator;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors NONE>;
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short,int,org.apache.kafkaesque.common.protocol.Errors,java.util.Iterator,int)>(v, 0, v, v, 0);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: int sizeOf()>();
v = 4 + v;
return v;
}
public boolean shouldClientThrottle(short)
{
short v;
boolean v;
org.apache.kafkaesque.common.requests.FetchResponse v;
v := @this: org.apache.kafkaesque.common.requests.FetchResponse;
v := @parameter: short;
if v < 8 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Int v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field$Str v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema 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;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("high_watermark", "Last committed offset.");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("log_start_offset", "Earliest available offset.");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("preferred_read_replica", "The ID of the replica that the consumer should prefer.");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PREFERRED_READ_REPLICA> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v[2] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_header", v);
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType RECORDS>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("record_set", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[1];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[0] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V1> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V1>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V2> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V2>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V3> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("last_stable_offset", "The last stable offset (or LSO) of the partition. This is the last offset such that the state of all transactional records prior to this offset have been decided (ABORTED or COMMITTED)");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("producer_id", "The producer id associated with the aborted transactions");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PRODUCER_ID> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("first_offset", "The first offset in the aborted transaction");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int FIRST_OFFSET> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PRODUCER_ID>;
v[0] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int FIRST_OFFSET>;
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_ABORTED_TRANSACTION_V4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[5];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v[2] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_ABORTED_TRANSACTION_V4>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.ArrayOf: org.apache.kafkaesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("aborted_transactions", v);
v[4] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[6];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v[2] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v[3] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_ABORTED_TRANSACTION_V4>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.ArrayOf: org.apache.kafkaesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("aborted_transactions", v);
v[5] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V5> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[7];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int HIGH_WATERMARK>;
v[2] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LAST_STABLE_OFFSET>;
v[3] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int LOG_START_OFFSET>;
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_ABORTED_TRANSACTION_V4>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.ArrayOf: org.apache.kafkaesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("aborted_transactions", v);
v[5] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int PREFERRED_READ_REPLICA>;
v[6] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V6> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V4>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_header", v);
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType RECORDS>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("record_set", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V5>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_header", v);
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType RECORDS>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("record_set", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V5> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_HEADER_V6>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_header", v);
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType RECORDS>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("record_set", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V6> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V4>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V5>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V5> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_PARTITION_V6>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("partition_responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V6> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V4>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V5>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V5> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V5>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V6> = v;
v = new org.apache.kafkaesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("session_id", "The fetch session ID");
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID>;
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V5>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[3] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V7> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V7>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V8> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V8>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V9> = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V9>;
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V10> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4];
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = <org.apache.kafkaesque.common.protocol.CommonFields: org.apache.kafkaesque.common.protocol.types.Field$Int ERROR_CODE>;
v[1] = v;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Field$Int SESSION_ID>;
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_TOPIC_V6>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type)>("responses", v);
v[3] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.types.Schema FETCH_RESPONSE_V11> = v;
return;
}
}