public class org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState 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 offlineReplicas; 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 SCHEMA_5; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_6; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesqueesqueesque.common.protocol.Readable, short) { org.apache.kafkaesqueesqueesque.common.protocol.Readable v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; short v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short) { org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; short v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.util.ArrayList v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; specialinvoke v.()>(); v. = ""; v. = 0; v. = 0; v. = 0; v. = 0; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = 0; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; return; } public short lowestSupportedVersion() { org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; return 0; } public short highestSupportedVersion() { org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; 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; java.util.List v, v; java.util.ArrayList v, v, v, v; short v, v; int 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; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable; v := @parameter: short; if v > 4 goto label; v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(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" (v) ("string field topicName had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; goto label; label: v. = ""; label: v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field isr was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; v = interfaceinvoke v.(); v. = v; if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field replicas was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; if v < 4 goto label; if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field offlineReplicas was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: v. = null; if v < 6 goto label; v = interfaceinvoke v.(); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); lookupswitch(v) { default: goto label; }; label: v = v.; v = interfaceinvoke v.(v, v, v); v. = 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; org.apache.kafkaesqueesqueesque.common.protocol.Writable v; boolean 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; short v; int 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; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; if v > 4 goto label; v = v.; v = virtualinvoke v.(v); v = lengthof v; interfaceinvoke v.(v); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v); if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: if v < 4 goto label; if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = 0 + v; if v < 6 goto label; interfaceinvoke v.(v); virtualinvoke v.(v, 2147483647); goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(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; java.util.Set v; java.util.List v, v, v, v; java.lang.Object[] v, v, v; java.util.ArrayList v, v, v, v, v; short v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v; java.util.Iterator v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v := @parameter: short; v. = null; if v < 6 goto label; v = virtualinvoke v.("_tagged_fields"); label: if v > 4 goto label; v = virtualinvoke v.("topic_name"); v. = v; goto label; label: v. = ""; label: v = virtualinvoke v.("partition_index"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("controller_epoch"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("leader"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("leader_epoch"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("isr"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; interfaceinvoke v.(v); v = v + 1; goto label; label: v = virtualinvoke v.("zk_version"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("replicas"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; interfaceinvoke v.(v); v = v + 1; goto label; label: if v < 4 goto label; v = virtualinvoke v.("offline_replicas"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; interfaceinvoke v.(v); v = v + 1; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 6 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = new java.util.ArrayList; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(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; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v; java.util.List v, v, v, v, v, v; java.lang.Integer[] v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v; short v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v; java.util.Iterator v, v, v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.util.TreeMap v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: short; v = null; if v < 6 goto label; v = new java.util.TreeMap; specialinvoke v.()>(); v = v; label: v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v); if v > 4 goto label; v = v.; virtualinvoke v.("topic_name", v); label: v = v.; v = staticinvoke (v); virtualinvoke v.("partition_index", v); v = v.; v = staticinvoke (v); virtualinvoke v.("controller_epoch", v); v = v.; v = staticinvoke (v); virtualinvoke v.("leader", v); v = v.; v = staticinvoke (v); virtualinvoke v.("leader_epoch", v); v = v.; v = interfaceinvoke v.(); v = newarray (java.lang.Integer)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v[v] = v; goto label; label: virtualinvoke v.("isr", v); v = v.; v = staticinvoke (v); virtualinvoke v.("zk_version", v); v = v.; v = interfaceinvoke v.(); v = newarray (java.lang.Integer)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v[v] = v; goto label; label: virtualinvoke v.("replicas", v); if v < 4 goto label; v = v.; v = interfaceinvoke v.(); v = newarray (java.lang.Integer)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v[v] = v; goto label; label: virtualinvoke v.("offline_replicas", v); label: if v < 6 goto label; virtualinvoke v.("_tagged_fields", v); label: return v; } public int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v; short 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; 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; java.util.Iterator v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.lang.Object v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; v = 0; if v > 4 goto label; v = v.; v = ; v = virtualinvoke v.(v); v = lengthof v; if v <= 32767 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("\'topicName\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(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 < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = interfaceinvoke v.(); v = v * 4; v = v + v; v = v + v; v = v + 4; if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = interfaceinvoke v.(); v = v * 4; v = v + v; v = v + v; if v < 4 goto label; if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = interfaceinvoke v.(); v = v * 4; v = v + v; v = v + v; label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = 0 + v; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = v + v; goto label; label: if v < 6 goto label; v = staticinvoke (v); v = v + v; goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } public boolean equals(java.lang.Object) { boolean v, v, v, v, v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.lang.Object v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: return 1; } public int hashCode() { java.util.List v, v, v, v, v, 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; java.lang.String v, v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = 0 + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; return v; } public java.lang.String toString() { int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; java.util.Iterator v, v, v; java.util.List v, v, v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = v.; v = v.; v = v.; v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v, v, v) ("UpdateMetadataPartitionState(topicName=\u, partitionIndex=\u, controllerEpoch=\u, leader=\u, leaderEpoch=\u, isr=\u, zkVersion=\u, replicas=\u, offlineReplicas=\u)"); return v; } public java.lang.String topicName() { org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.lang.String v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public int partitionIndex() { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public int controllerEpoch() { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public int leader() { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public int leaderEpoch() { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public java.util.List isr() { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public int zkVersion() { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public java.util.List replicas() { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public java.util.List offlineReplicas() { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.util.ArrayList v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v = v.; if v != null goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(0); v. = v; label: v = v.; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setTopicName(java.lang.String) { org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.lang.String v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setPartitionIndex(int) { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setControllerEpoch(int) { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setLeader(int) { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setLeaderEpoch(int) { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setIsr(java.util.List) { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setZkVersion(int) { int v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setReplicas(java.util.List) { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState setOfflineReplicas(java.util.List) { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; v := @this: org.apache.kafkaesqueesqueesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; v := @parameter: java.util.List; v. = v; return v; } static void () { org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf 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; org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v, 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; 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 = 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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topic_name", v, "In older versions of this RPC, the topic name."); v[0] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(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 = ; specialinvoke v.(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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The ID of the broker which is the current partition leader."); v[3] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch of this partition."); v[4] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The brokers which are in the ISR for this partition."); v[5] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(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 = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "All the replicas of this partition."); v[7] = v; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = ; = v; v = ; = 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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topic_name", v, "In older versions of this RPC, the topic name."); v[0] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(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 = ; specialinvoke v.(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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The ID of the broker which is the current partition leader."); v[3] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("leader_epoch", v, "The leader epoch of this partition."); v[4] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("isr", v, "The brokers which are in the ISR for this partition."); v[5] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(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 = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "All the replicas of this partition."); v[7] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("offline_replicas", v, "The replicas of this partition which are offline."); v[8] = v; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(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 = ; specialinvoke v.(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 = ; specialinvoke v.(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 =