public class org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.Message
{
private int partitionIndex;
private short errorCode;
private long highWatermark;
private long lastStableOffset;
private long logStartOffset;
private java.util.List aborted;
private int preferredReadReplica;
private byte[] records;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_10;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_11;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
short v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: void read(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
short v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
byte[] v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex> = 0;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode> = 0;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark> = 0L;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = -1L;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = -1L;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = 0;
v = <org.apache.kafkaesqueesque.common.utils.Bytes: byte[] EMPTY>;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
return 11;
}
public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
byte[] v;
long v, v, v;
java.util.ArrayList v, v;
short v, v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
if v <= 11 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t read version \u of FetchablePartitionResponse");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark> = v;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = -1L;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = -1L;
label:
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
if v >= 0 goto label;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = null;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
label:
if v < 11 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = 0;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
if v >= 0 goto label;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records> = null;
goto label;
label:
v = newarray (byte)[v];
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: void readArray(byte[])>(v);
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records> = v;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields> = null;
return;
}
public void write(org.apache.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v;
boolean v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v, v;
java.util.List v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Writable v;
long v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v;
short v, v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v;
java.lang.Object v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 11 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t write version \u of FetchablePartitionResponse");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeLong(long)>(v);
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeLong(long)>(v);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeLong(long)>(v);
label:
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
v = (int) -1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
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()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: void write(org.apache.kafkaesqueesque.common.protocol.Writable,org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
label:
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default aborted at version \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 11 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
if v != null goto label;
v = (int) -1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
byte[] v;
java.lang.Object[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
long v, v, v;
java.lang.Integer v, v;
java.util.ArrayList v, v;
short v, v;
java.lang.Long v, v, v;
java.lang.Short v;
int v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v;
java.lang.Object v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 11 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t read version \u of FetchablePartitionResponse");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields> = null;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("partition_index");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Short getShort(java.lang.String)>("error_code");
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("high_watermark");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark> = v;
if v < 4 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("last_stable_offset");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = -1L;
label:
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("log_start_offset");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = -1L;
label:
if v < 4 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("aborted");
if v != null goto label;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = null;
goto label;
label:
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = new org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
label:
if v < 11 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("preferred_read_replica");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = 0;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: byte[] getByteArray(java.lang.String)>("records");
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records> = v;
return;
}
public org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
byte[] v;
java.lang.Integer v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Long v, v, v;
java.lang.Short v;
boolean v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v, v;
long v, v, v;
short v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct[] v;
int v, v, v, v, v;
java.lang.String v, v;
java.util.Iterator v;
java.lang.Object v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: short;
if v <= 11 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t write version \u of FetchablePartitionResponse");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[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.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
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 set(java.lang.String,java.lang.Object)>("partition_index", v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("error_code", v);
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
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 set(java.lang.String,java.lang.Object)>("high_watermark", v);
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
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 set(java.lang.String,java.lang.Object)>("last_stable_offset", v);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: 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 set(java.lang.String,java.lang.Object)>("log_start_offset", v);
label:
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("aborted", null);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
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 = v;
v = v + 1;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("aborted", v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
label:
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default aborted at version \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 11 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
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 set(java.lang.String,java.lang.Object)>("preferred_read_replica", v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct setByteArray(java.lang.String,byte[])>("records", v);
return v;
}
public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v;
boolean v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v, v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 11 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t size version \u of FetchablePartitionResponse");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 14;
if v < 4 goto label;
v = 22;
label:
if v < 5 goto label;
v = v + 8;
label:
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
v = v + 4;
goto label;
label:
v = 4;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
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.message.FetchResponseData$AbortedTransaction: int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
label:
if v < 11 goto label;
v = v + 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
if v != null goto label;
v = v + 4;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = lengthof v;
v = v + 4;
v = v + v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
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.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
byte[] v, v;
long v, v, v, v, v, v;
short v, v;
byte v, v, v;
int v, v, v, v;
boolean v, v, v;
java.util.List v, v, v, v;
java.lang.Object v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = staticinvoke <java.util.Arrays: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
byte[] v;
java.util.List v, v;
long v, v, v, v, v, v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
v = v >> 32;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
v = v >> 32;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
v = v >> 32;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = staticinvoke <java.util.Arrays: int hashCode(byte[])>(v);
v = v + v;
return v;
}
public java.lang.String toString()
{
byte[] v;
java.util.Iterator v;
long v, v, v;
java.util.List v, v;
short v;
int v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
v = staticinvoke <java.util.Arrays: java.lang.String toString(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,short,long,long,long,java.lang.String,int,java.lang.String)>(v, v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("FetchablePartitionResponse(partitionIndex=\u, errorCode=\u, highWatermark=\u, lastStableOffset=\u, logStartOffset=\u, aborted=\u, preferredReadReplica=\u, records=\u)");
return v;
}
public int partitionIndex()
{
int v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex>;
return v;
}
public short errorCode()
{
short v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode>;
return v;
}
public long highWatermark()
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark>;
return v;
}
public long lastStableOffset()
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset>;
return v;
}
public long logStartOffset()
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset>;
return v;
}
public java.util.List aborted()
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted>;
return v;
}
public int preferredReadReplica()
{
int v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica>;
return v;
}
public byte[] records()
{
byte[] v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setPartitionIndex(int)
{
int v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int partitionIndex> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setErrorCode(short)
{
short v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: short errorCode> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setHighWatermark(long)
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: long;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long highWatermark> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setLastStableOffset(long)
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: long;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long lastStableOffset> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setLogStartOffset(long)
{
long v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: long;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: long logStartOffset> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setAborted(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: java.util.List aborted> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setPreferredReadReplica(int)
{
int v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: int preferredReadReplica> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse setRecords(byte[])
{
byte[] v;
org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse v;
v := @this: org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse;
v := @parameter: byte[];
v.<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: byte[] records> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.ArrayOf 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, v, v, v, v, v;
org.apache.kafkaesqueesque.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;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, 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 = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
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: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partiiton index.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no fetch error.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("high_watermark", v, "The current high water mark.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType NULLABLE_BYTES>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("records", v, "The record data.");
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.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[6];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
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: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partiiton index.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no fetch error.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("high_watermark", v, "The current high water mark.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("last_stable_offset", v, "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)");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: org.apache.kafkaesqueesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("aborted", v, "The aborted transactions.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType NULLABLE_BYTES>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("records", v, "The record data.");
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.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[7];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
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: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partiiton index.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no fetch error.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("high_watermark", v, "The current high water mark.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("last_stable_offset", v, "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)");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("log_start_offset", v, "The current log start offset.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: org.apache.kafkaesqueesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("aborted", v, "The aborted transactions.");
v[5] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType NULLABLE_BYTES>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("records", v, "The record data.");
v[6] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9> = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9>;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_10> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[8];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
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: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partiiton index.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no fetch error.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("high_watermark", v, "The current high water mark.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("last_stable_offset", v, "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)");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("log_start_offset", v, "The current log start offset.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$AbortedTransaction: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: org.apache.kafkaesqueesque.common.protocol.types.ArrayOf nullable(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("aborted", v, "The aborted transactions.");
v[5] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
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: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("preferred_read_replica", v, "The preferred read replica for the consumer to use on its next fetch request");
v[6] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType NULLABLE_BYTES>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("records", v, "The record data.");
v[7] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_11> = v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[12];
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8>;
v[8] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9>;
v[9] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_10>;
v[10] = v;
v = <org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_11>;
v[11] = v;
<org.apache.kafkaesqueesque.common.message.FetchResponseData$FetchablePartitionResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}