public class org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState extends java.lang.Object implements org.apache.kafkaesqueesqueesque.common.protocol.Message
{
private java.lang.String topicName;
private int partitionIndex;
private int controllerEpoch;
private int leader;
private int leaderEpoch;
private java.util.List isr;
private int zkVersion;
private java.util.List replicas;
private java.util.List addingReplicas;
private java.util.List removingReplicas;
private boolean isNew;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
java.util.ArrayList v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = "";
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex> = 0;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch> = 0;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader> = 0;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr> = v;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = 0;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
return 32767;
}
public void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
java.lang.Integer v, v, v, v;
byte v;
boolean v;
java.util.List v, v;
java.util.ArrayList v, v, v, v, v, v;
short v, v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState 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;
java.lang.String v, v;
java.lang.RuntimeException v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
if v > 1 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: short readShort()>();
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field topicName was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
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[])>("string field topicName had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = "";
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch> = v;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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 isr 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.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion> = v;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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 replicas 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.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas> = v;
if v < 3 goto label;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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 addingReplicas 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.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
label:
if v < 3 goto label;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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 removingReplicas 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.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
label:
if v < 1 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: byte readByte()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = 0;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields> = null;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable, org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
byte v;
org.apache.kafkaesqueesqueesque.common.protocol.Writable v;
boolean v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState 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;
java.lang.String v, v;
java.util.Iterator v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v > 1 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeShort(short)>(v);
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
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.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
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.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
if v < 3 goto label;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
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.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
if v < 3 goto label;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
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.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
if v < 1 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByte(byte)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 4 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesqueesqueesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
java.lang.Integer v, v, v, v, v;
boolean v, v, v;
java.util.Set v;
java.util.List v, v, v, v, v;
java.lang.Object[] v, v, v, v;
java.util.ArrayList v, v, v, v, v, v, v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.lang.String v;
java.util.Iterator v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields> = null;
if v < 4 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
if v > 1 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("topic_name");
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = "";
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("partition_index");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("controller_epoch");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("leader");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("leader_epoch");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("isr");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("zk_version");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
if v < 3 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("adding_replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
label:
if v < 3 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("removing_replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
label:
if v < 1 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Boolean getBoolean(java.lang.String)>("is_new");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = 0;
label:
if v < 4 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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: 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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: 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.kafkaesqueesqueesque.common.protocol.types.Struct toStruct(short)
{
java.lang.Integer v, v, v, v, v;
boolean v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v;
java.util.List v, v, v, v, v, v, v, v;
java.lang.Integer[] v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.lang.String v;
java.util.Iterator v, v, v, v;
java.util.TreeMap v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: short;
v = null;
if v < 4 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v);
if v > 1 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("topic_name", v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_index", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("controller_epoch", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("leader", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("leader_epoch", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
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.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("isr", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("zk_version", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
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.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("replicas", v);
if v < 3 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
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.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("adding_replicas", v);
if v < 3 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
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.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("removing_replicas", v);
label:
if v < 1 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("is_new", v);
label:
if v < 4 goto label;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
java.lang.String v, v, v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
boolean v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v, v, v, v, v, v, v, v, v, v, v;
java.nio.charset.Charset 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = 0;
if v > 1 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'topicName\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
v = lengthof v;
v = v + 2;
v = 0 + v;
label:
v = v + 4;
v = v + 4;
v = v + 4;
v = v + 4;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
v = v + 4;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
if v < 3 goto label;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
if v < 3 goto label;
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
label:
if v < 1 goto label;
v = v + 1;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: 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.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 4 goto label;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
boolean v, v, v, v, v, v, v, v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
if v == v goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
boolean v;
java.util.List v, v, v, v, v, v, v, v;
short v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState 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;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
if v == 0 goto label;
v = 1231;
goto label;
label:
v = 1237;
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v;
java.util.Iterator v, v, v, v;
java.util.List v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
if v == 0 goto label;
v = "true";
goto label;
label:
v = "false";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,int,int,int,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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[])>("LeaderAndIsrPartitionState(topicName=\u, partitionIndex=\u, controllerEpoch=\u, leader=\u, leaderEpoch=\u, isr=\u, zkVersion=\u, replicas=\u, addingReplicas=\u, removingReplicas=\u, isNew=\u)");
return v;
}
public java.lang.String topicName()
{
java.lang.String v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName>;
return v;
}
public int partitionIndex()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex>;
return v;
}
public int controllerEpoch()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch>;
return v;
}
public int leader()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader>;
return v;
}
public int leaderEpoch()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch>;
return v;
}
public java.util.List isr()
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr>;
return v;
}
public int zkVersion()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion>;
return v;
}
public java.util.List replicas()
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas>;
return v;
}
public java.util.List addingReplicas()
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas>;
return v;
}
public java.util.List removingReplicas()
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas>;
return v;
}
public boolean isNew()
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: 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.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setTopicName(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.lang.String topicName> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setPartitionIndex(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int partitionIndex> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setControllerEpoch(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int controllerEpoch> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setLeader(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leader> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setLeaderEpoch(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int leaderEpoch> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setIsr(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List isr> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setZkVersion(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: int zkVersion> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List replicas> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setAddingReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List addingReplicas> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setRemovingReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: java.util.List removingReplicas> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState setIsNew(boolean)
{
org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState;
v := @parameter: boolean;
v.<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: boolean isNew> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v, v, v;
java.lang.Object[] v;
org.apache.kafkaesqueesqueesque.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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field[] v, v, v, v, v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[8];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topic_name", v, "The topic name.  This is only present in v or v.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The broker ID of the leader.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The in-sync replica IDs.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("zk_version", v, "The ZooKeeper version.");
v[6] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The replica IDs.");
v[7] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[9];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topic_name", v, "The topic name.  This is only present in v or v.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The broker ID of the leader.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The in-sync replica IDs.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("zk_version", v, "The ZooKeeper version.");
v[6] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The replica IDs.");
v[7] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("is_new", v, "Whether the replica should have existed on the broker or not.");
v[8] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[8];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The broker ID of the leader.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The in-sync replica IDs.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("zk_version", v, "The ZooKeeper version.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The replica IDs.");
v[6] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("is_new", v, "Whether the replica should have existed on the broker or not.");
v[7] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[10];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The broker ID of the leader.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The in-sync replica IDs.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("zk_version", v, "The ZooKeeper version.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The replica IDs.");
v[6] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("adding_replicas", v, "The replica IDs that we are adding this partition to, or null if no replicas are being added.");
v[7] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("removing_replicas", v, "The replica IDs that we are removing this partition from, or null if no replicas are being removed.");
v[8] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("is_new", v, "Whether the replica should have existed on the broker or not.");
v[9] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[11];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The broker ID of the leader.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The in-sync replica IDs.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("zk_version", v, "The ZooKeeper version.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The replica IDs.");
v[6] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("adding_replicas", v, "The replica IDs that we are adding this partition to, or null if no replicas are being added.");
v[7] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("removing_replicas", v, "The replica IDs that we are removing this partition from, or null if no replicas are being removed.");
v[8] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("is_new", v, "Whether the replica should have existed on the broker or not.");
v[9] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[10] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4> = v;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)[5];
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
<org.apache.kafkaesqueesqueesque.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}