public class org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.Message
{
private short errorCode;
private int partitionIndex;
private int leaderId;
private int leaderEpoch;
private java.util.List replicaNodes;
private java.util.List isrNodes;
private java.util.List offlineReplicas;
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[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
short v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
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.MetadataResponseData$MetadataResponsePartition: void read(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
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.MetadataResponseData$MetadataResponsePartition: void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.ArrayList v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode> = 0;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex> = 0;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId> = 0;
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
return 9;
}
public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
java.lang.Integer v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v;
java.util.ArrayList v, v, v, v;
short v, v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int 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.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v;
java.lang.RuntimeException v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
if v <= 9 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 MetadataResponsePartition");
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: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId> = v;
if v < 7 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
label:
if v < 9 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field replicaNodes was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes> = v;
if v < 9 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field isrNodes was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes> = v;
if v < 5 goto label;
if v < 9 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field offlineReplicas was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
label:
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields> = null;
if v < 9 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
boolean v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Writable v;
org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 9 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 MetadataResponsePartition");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 7 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
if v < 5 goto label;
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: 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 < 9 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesqueesque.common.protocol.Writable,int)>(v, 2147483647);
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;
}
public void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
java.lang.Integer v, v, v;
java.lang.Short v;
boolean v, v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v;
java.lang.Object[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.util.ArrayList v, v, v, v, v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v;
java.util.Iterator v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 9 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 MetadataResponsePartition");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields> = null;
if v < 9 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
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.MetadataResponseData$MetadataResponsePartition: short errorCode> = v;
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.MetadataResponseData$MetadataResponsePartition: int partitionIndex> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("leader_id");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId> = v;
if v < 7 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("leader_epoch");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("replica_nodes");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("isr_nodes");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("offline_replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
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.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
label:
if v < 9 goto label;
v = interfaceinvoke v.<java.util.NavigableMap: boolean isEmpty()>();
if v != 0 goto label;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.NavigableMap: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields> = v;
v = interfaceinvoke v.<java.util.NavigableMap: 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 = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
java.lang.Integer v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Short v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v, v, v;
java.lang.Integer[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v;
java.util.Iterator v, v, v;
java.util.TreeMap v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: short;
if v <= 9 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 MetadataResponsePartition");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
if v < 9 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: 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.MetadataResponseData$MetadataResponsePartition: 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.MetadataResponseData$MetadataResponsePartition: 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.MetadataResponseData$MetadataResponsePartition: int leaderId>;
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)>("leader_id", v);
if v < 7 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
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)>("leader_epoch", v);
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
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[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)>("replica_nodes", v);
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
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[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)>("isr_nodes", v);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
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[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)>("offline_replicas", v);
label:
if v < 9 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)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
boolean v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List 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, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 9 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 MetadataResponsePartition");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 10;
if v < 7 goto label;
v = 14;
label:
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
if v < 5 goto label;
if v < 9 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: 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 < 9 goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
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)
{
short v, v;
int v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
boolean v, v, v, v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
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.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
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.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
java.util.Iterator v, v, v;
java.util.List v, v, v;
short v;
int v, v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.lang.String v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
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);
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
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);
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
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);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short,int,int,int,java.lang.String,java.lang.String,java.lang.String)>(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[])>("MetadataResponsePartition(errorCode=\u, partitionIndex=\u, leaderId=\u, leaderEpoch=\u, replicaNodes=\u, isrNodes=\u, offlineReplicas=\u)");
return v;
}
public short errorCode()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
short v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode>;
return v;
}
public int partitionIndex()
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex>;
return v;
}
public int leaderId()
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId>;
return v;
}
public int leaderEpoch()
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch>;
return v;
}
public java.util.List replicaNodes()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes>;
return v;
}
public java.util.List isrNodes()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes>;
return v;
}
public java.util.List offlineReplicas()
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: 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.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setErrorCode(short)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
short v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: short errorCode> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setPartitionIndex(int)
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int partitionIndex> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setLeaderId(int)
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderId> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setLeaderEpoch(int)
{
int v;
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: int leaderEpoch> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setReplicaNodes(java.util.List)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List replicaNodes> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setIsrNodes(java.util.List)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List isrNodes> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition setOfflineReplicas(java.util.List)
{
org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: java.util.List offlineReplicas> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesqueesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v;
java.lang.Object[] 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;
org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf 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, 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)[5];
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 partition error, or 0 if there was no error.");
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 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 partition index.");
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 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)>("leader_id", v, "The ID of the leader broker.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("replica_nodes", v, "The set of all nodes that host this partition.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("isr_nodes", v, "The set of nodes that are in sync with the leader for this partition.");
v[4] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: 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)[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 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 partition error, or 0 if there was no error.");
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 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 partition index.");
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 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)>("leader_id", v, "The ID of the leader broker.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("replica_nodes", v, "The set of all nodes that host this partition.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("isr_nodes", v, "The set of nodes that are in sync with the leader for this partition.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("offline_replicas", v, "The set of offline replicas of this partition.");
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.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6> = 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 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 partition error, or 0 if there was no error.");
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 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 partition index.");
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 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)>("leader_id", v, "The ID of the leader broker.");
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 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)>("leader_epoch", v, "The leader epoch of this partition.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("replica_nodes", v, "The set of all nodes that host this partition.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("isr_nodes", v, "The set of nodes that are in sync with the leader for this partition.");
v[5] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
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.ArrayOf: void <init>(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)>("offline_replicas", v, "The set of offline replicas of this partition.");
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.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7> = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7>;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8> = 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 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 partition error, or 0 if there was no error.");
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 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 partition index.");
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 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)>("leader_id", v, "The ID of the leader broker.");
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 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)>("leader_epoch", v, "The leader epoch of this partition.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
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.CompactArrayOf: void <init>(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)>("replica_nodes", v, "The set of all nodes that host this partition.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
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.CompactArrayOf: void <init>(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)>("isr_nodes", v, "The set of nodes that are in sync with the leader for this partition.");
v[5] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
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.CompactArrayOf: void <init>(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)>("offline_replicas", v, "The set of offline replicas of this partition.");
v[6] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
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.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9> = v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[10];
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6>;
v[6] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7>;
v[7] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8>;
v[8] = v;
v = <org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9>;
v[9] = v;
<org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponsePartition: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}