public class org.apache.kafkaesqueesque.common.message.MetadataResponseData extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.ApiMessage { private int throttleTimeMs; private org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection brokers; private java.lang.String clusterId; private int controllerId; private org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection topics; private int clusterAuthorizedOperations; private java.util.List _unknownTaggedFields; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_6; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesqueesque.common.protocol.Readable, short) { short v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.protocol.Readable v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesqueesque.common.protocol.types.Struct, short) { short v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.protocol.types.Struct v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; specialinvoke v.()>(); v. = 0; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection; specialinvoke v.(int)>(0); v. = v; v. = null; v = (int) -1; v. = v; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection; specialinvoke v.(int)>(0); v. = v; v. = -2147483648; return; } public short apiKey() { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; return 3; } public short lowestSupportedVersion() { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; return 9; } public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short) { org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBroker v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopic v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v; java.util.List v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; short v, v; org.apache.kafkaesqueesque.common.protocol.Readable v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; java.lang.RuntimeException v, v, v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable; v := @parameter: short; if v < 3 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = 0; label: if v < 9 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field brokers was serialized as null"); throw v; label: v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBroker; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field brokers was serialized as null"); throw v; label: v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBroker; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; label: if v < 2 goto label; if v < 9 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; v. = null; goto label; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field clusterId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; goto label; label: v. = null; label: if v < 1 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: if v < 9 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field topics was serialized as null"); throw v; label: v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field topics was serialized as null"); throw v; label: v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; label: if v < 8 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = -2147483648; label: v. = null; if v < 9 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.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v, v, v; boolean v, v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v; java.util.List v; org.apache.kafkaesqueesque.common.protocol.Writable v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v; short v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v, v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; if v < 3 goto label; v = v.; interfaceinvoke v.(v); label: if v < 9 goto label; v = v.; v = virtualinvoke v.(); v = v + 1; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v < 2 goto label; v = v.; if v != null goto label; if v < 9 goto label; interfaceinvoke v.(0); goto label; label: v = (short) -1; interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(v); if v < 9 goto label; v = lengthof v; v = v + 1; interfaceinvoke v.(v); goto label; label: v = lengthof v; interfaceinvoke v.(v); label: interfaceinvoke v.(v); label: if v < 1 goto label; v = v.; interfaceinvoke v.(v); label: if v < 9 goto label; v = v.; v = virtualinvoke v.(); v = v + 1; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v < 8 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; if v == -2147483648 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default clusterAuthorizedOperations at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = 0 + v; if v < 9 goto label; interfaceinvoke v.(v); virtualinvoke v.(v, 2147483647); goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesque.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.kafkaesqueesque.common.protocol.types.Struct, short) { java.lang.Integer v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBroker v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopic v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v; boolean v, v; java.util.Set v; java.util.List v; java.lang.Object[] v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.protocol.types.Struct v; java.util.ArrayList v; short v; int v, v, v, v, v, v, v, v, v, v, v; java.lang.String v; java.util.Iterator v; java.lang.Object v, v, v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct; v := @parameter: short; v. = null; if v < 9 goto label; v = virtualinvoke v.("_tagged_fields"); label: if v < 3 goto label; v = virtualinvoke v.("throttle_time_ms"); v = virtualinvoke v.(); v. = v; goto label; label: v. = 0; label: v = virtualinvoke v.("brokers"); v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection; 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.; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBroker; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: if v < 2 goto label; v = virtualinvoke v.("cluster_id"); v. = v; goto label; label: v. = null; label: if v < 1 goto label; v = virtualinvoke v.("controller_id"); v = virtualinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: v = virtualinvoke v.("topics"); v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection; 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.; v = new org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: if v < 8 goto label; v = virtualinvoke v.("cluster_authorized_operations"); v = virtualinvoke v.(); v. = v; goto label; label: v. = -2147483648; label: if v < 9 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.kafkaesqueesque.common.protocol.types.Struct toStruct(short) { java.lang.Integer v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v; boolean v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v; org.apache.kafkaesqueesque.common.protocol.types.Schema[] v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.protocol.types.Struct v, v, v; short v; org.apache.kafkaesqueesque.common.protocol.types.Struct[] v, v; int v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; java.util.Iterator v, v; java.util.TreeMap v, v; java.lang.Object v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: short; v = null; if v < 9 goto label; v = new java.util.TreeMap; specialinvoke v.()>(); v = v; label: v = new org.apache.kafkaesqueesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v); if v < 3 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("throttle_time_ms", v); label: v = v.; v = virtualinvoke v.(); v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("brokers", v); if v < 2 goto label; v = v.; virtualinvoke v.("cluster_id", v); label: if v < 1 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("controller_id", v); label: v = v.; v = virtualinvoke v.(); v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("topics", v); if v < 8 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("cluster_authorized_operations", v); goto label; label: v = v.; if v == -2147483648 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default clusterAuthorizedOperations at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 9 goto label; virtualinvoke v.("_tagged_fields", v); label: return v; } public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v; boolean v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v; java.util.List v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; short 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; java.lang.String v, v, v, v; org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v; java.util.Iterator v, v, v; java.lang.RuntimeException v; java.lang.Object v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; v = 0; if v < 3 goto label; v = 4; label: if v < 9 goto label; v = v.; v = virtualinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; if v < 2 goto label; v = v.; if v != null goto label; if v < 9 goto label; v = v + 1; goto label; label: v = v + 2; goto label; 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)>("\'clusterId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 9 goto label; v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = v + v; goto label; label: v = lengthof v; v = v + 2; v = v + v; label: if v < 1 goto label; v = v + 4; label: if v < 9 goto label; v = v.; v = virtualinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; if v < 8 goto label; v = v + 4; 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 < 9 goto label; v = staticinvoke (v); v = v + v; goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesque.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) { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; int v, v, v, v, v, v; java.lang.String v, v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v, v, v; boolean v, v, v, v; java.lang.Object v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v, v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesqueesque.common.message.MetadataResponseData; 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 = virtualinvoke 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 = 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.; 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: return 1; } public int hashCode() { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v, v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; v = 0 + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke 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 = virtualinvoke v.(); label: v = v + v; v = 31 * v; v = v.; v = v + v; return v; } public java.lang.String toString() { java.util.Iterator v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; int v, v, v; java.lang.String v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); 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 = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v) ("MetadataResponseData(throttleTimeMs=\u, brokers=\u, clusterId=\u, controllerId=\u, topics=\u, clusterAuthorizedOperations=\u)"); return v; } public int throttleTimeMs() { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection brokers() { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public java.lang.String clusterId() { java.lang.String v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public int controllerId() { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection topics() { org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public int clusterAuthorizedOperations() { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; java.util.ArrayList v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; 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.kafkaesqueesque.common.message.MetadataResponseData setThrottleTimeMs(int) { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData setBrokers(org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection) { org.apache.kafkaesqueesque.common.message.MetadataResponseData v; org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseBrokerCollection; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData setClusterId(java.lang.String) { java.lang.String v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData setControllerId(int) { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData setTopics(org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection) { org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: org.apache.kafkaesqueesque.common.message.MetadataResponseData$MetadataResponseTopicCollection; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.MetadataResponseData setClusterAuthorizedOperations(int) { int v; org.apache.kafkaesqueesque.common.message.MetadataResponseData v; v := @this: org.apache.kafkaesqueesque.common.message.MetadataResponseData; v := @parameter: int; v. = v; return v; } static void () { org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection v; org.apache.kafkaesqueesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object[] v; org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf v, v; org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema[] v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[1] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[3]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[2] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_id", v, "The cluster ID that responding broker belongs to."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[3] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_id", v, "The cluster ID that responding broker belongs to."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_id", v, "The cluster ID that responding broker belongs to."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_id", v, "The cluster ID that responding broker belongs to."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[6]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("brokers", v, "Each broker in the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_id", v, "The cluster ID that responding broker belongs to."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The ID of the controller broker."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the response."); v[4] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("cluster_authorized_operations", v, "32-bit bitfield to represent authorized operations for this cluster."); v[5] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[7]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.