public class org.apache.kafkaesque.common.message.JoinGroupResponseData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage { private int throttleTimeMs; private short errorCode; private int generationId; private java.lang.String protocolType; private java.lang.String protocolName; private java.lang.String leader; private java.lang.String memberId; private java.util.List members; private java.util.List _unknownTaggedFields; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6; public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_7; public static final org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesque.common.protocol.Readable, short) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; org.apache.kafkaesque.common.protocol.Readable v; short v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesque.common.protocol.types.Struct, short) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; org.apache.kafkaesque.common.protocol.types.Struct v; short v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { int v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.util.ArrayList v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; specialinvoke v.()>(); v. = 0; v. = 0; v = (int) -1; v. = v; v. = null; v. = ""; v. = ""; v. = ""; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; return; } public short apiKey() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; return 11; } public short lowestSupportedVersion() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; return 7; } public void read(org.apache.kafkaesque.common.protocol.Readable, short) { java.util.List v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v, v; java.util.ArrayList v, v; short 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; java.lang.String v, v, v, v, v, v, v, v; java.lang.RuntimeException v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; org.apache.kafkaesque.common.protocol.Readable v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.Readable; v := @parameter: short; if v < 2 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = 0; label: v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; if v < 7 goto label; v = interfaceinvoke v.(); v = v - 1; 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 protocolType 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 < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; if v < 7 goto label; v. = null; goto label; label: v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field protocolName was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field protocolName had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; label: if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field leader was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field leader had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field memberId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field memberId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; if v < 6 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 members 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 = new org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember; specialinvoke v.(org.apache.kafkaesque.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 members 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 = new org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: 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.kafkaesque.common.protocol.Writable, org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short) { byte[] v, v, v, v; java.lang.NullPointerException v; boolean v, v; org.apache.kafkaesque.common.protocol.Writable v; java.util.List v, v, v, v, v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v; short v, v, v; int 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, v, v, v; java.util.Iterator v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.Object v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; if v < 2 goto label; v = v.; interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); if v < 7 goto label; v = v.; if v != null goto label; interfaceinvoke v.(0); goto label; label: v = v.; v = virtualinvoke v.(v); v = lengthof v; v = v + 1; interfaceinvoke v.(v); interfaceinvoke v.(v); label: v = v.; if v != null goto label; if v < 7 goto label; if v < 6 goto label; interfaceinvoke v.(0); goto label; label: v = (short) -1; interfaceinvoke v.(v); goto label; label: v = new java.lang.NullPointerException; specialinvoke v.()>(); throw v; label: v = v.; v = virtualinvoke v.(v); if v < 6 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: v = v.; v = virtualinvoke v.(v); if v < 6 goto label; v = lengthof v; v = v + 1; interfaceinvoke v.(v); goto label; label: v = lengthof v; interfaceinvoke v.(v); label: interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v < 6 goto label; v = lengthof v; v = v + 1; interfaceinvoke v.(v); goto label; label: v = lengthof v; interfaceinvoke v.(v); label: interfaceinvoke v.(v); if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, 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.kafkaesque.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.kafkaesque.common.protocol.types.Struct, short) { java.lang.Object[] v; org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v; java.lang.Integer v, v; java.util.ArrayList v, v; short v, v; java.lang.Short v; int v, v, v, v, v, v; java.lang.String v, v, v, v; boolean v, v; java.util.Iterator v; java.util.Set v; org.apache.kafkaesque.common.protocol.types.Struct v; java.util.List v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.Object v, v, v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct; v := @parameter: short; v. = null; if v < 6 goto label; v = virtualinvoke v.("_tagged_fields"); label: if v < 2 goto label; v = virtualinvoke v.("throttle_time_ms"); v = virtualinvoke v.(); v. = v; goto label; label: v. = 0; label: v = virtualinvoke v.("error_code"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("generation_id"); v = virtualinvoke v.(); v. = v; if v < 7 goto label; v = virtualinvoke v.("protocol_type"); v. = v; goto label; label: v. = null; label: v = virtualinvoke v.("protocol_name"); v. = v; v = virtualinvoke v.("leader"); v. = v; v = virtualinvoke v.("member_id"); v. = v; v = virtualinvoke v.("members"); 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.; v = new org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; 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.kafkaesque.common.protocol.types.Struct toStruct(short) { java.lang.Integer v, v; org.apache.kafkaesque.common.protocol.types.Schema v; short v, v; java.lang.Short v; int v, v, v, v, v; java.lang.String v, v, v, v; boolean v; java.util.Iterator v; org.apache.kafkaesque.common.protocol.types.Schema[] v; org.apache.kafkaesque.common.protocol.types.Struct[] v; org.apache.kafkaesque.common.protocol.types.Struct v, v; java.util.List v, v; java.util.TreeMap v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.Object v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: short; v = null; if v < 6 goto label; v = new java.util.TreeMap; specialinvoke v.()>(); v = v; label: v = new org.apache.kafkaesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Schema)>(v); if v < 2 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("throttle_time_ms", v); label: v = v.; v = staticinvoke (v); virtualinvoke v.("error_code", v); v = v.; v = staticinvoke (v); virtualinvoke v.("generation_id", v); if v < 7 goto label; v = v.; virtualinvoke v.("protocol_type", v); label: v = v.; virtualinvoke v.("protocol_name", v); v = v.; virtualinvoke v.("leader", v); v = v.; virtualinvoke v.("member_id", v); v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[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 = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("members", v); if v < 6 goto label; virtualinvoke v.("_tagged_fields", v); label: return v; } public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short) { byte[] v, v, v, v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; short v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v; java.lang.RuntimeException v, v, v, v; boolean v, v; java.util.List v, v, v, v, v; java.nio.charset.Charset 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, 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, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.Object v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; v = 0; if v < 2 goto label; v = 4; label: v = v + 2; v = v + 4; if v < 7 goto label; v = v.; if v != null goto label; v = v + 1; 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)>("\'protocolType\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = v + v; label: v = v.; if v != null goto label; if v < 6 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)>("\'protocolName\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 6 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: 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)>("\'leader\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 6 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: 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)>("\'memberId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 6 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 < 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.(); 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; 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.kafkaesque.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, v; java.util.List v, v, v, v; short v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.Object v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesque.common.message.JoinGroupResponseData; 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.; 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.; 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.; 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; short v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; v = 0 + 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 = 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.; 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.; 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() { short v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.util.List v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; v = v.; v = 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.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: 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.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v, v) ("JoinGroupResponseData(throttleTimeMs=\u, errorCode=\u, generationId=\u, protocolType=\u, protocolName=\u, leader=\u, memberId=\u, members=\u)"); return v; } public int throttleTimeMs() { int v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public short errorCode() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; short v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public int generationId() { int v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.lang.String protocolType() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.lang.String protocolName() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.lang.String leader() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.lang.String memberId() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.util.List members() { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.util.ArrayList v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; 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.kafkaesque.common.message.JoinGroupResponseData setThrottleTimeMs(int) { int v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setErrorCode(short) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; short v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: short; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setGenerationId(int) { int v; org.apache.kafkaesque.common.message.JoinGroupResponseData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setProtocolType(java.lang.String) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setProtocolName(java.lang.String) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setLeader(java.lang.String) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setMemberId(java.lang.String) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.lang.String v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupResponseData setMembers(java.util.List) { org.apache.kafkaesque.common.message.JoinGroupResponseData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData; v := @parameter: java.util.List; v. = v; return v; } static void () { org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v; java.lang.Object[] v, v; org.apache.kafkaesque.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; org.apache.kafkaesque.common.protocol.types.CompactArrayOf v, v; org.apache.kafkaesque.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; org.apache.kafkaesque.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; org.apache.kafkaesque.common.protocol.types.Schema[] v; org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v, v; org.apache.kafkaesque.common.protocol.types.Field[] v, v, v, v, v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[6]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no error."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation ID of the group."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("protocol_name", v, "The group protocol selected by the coordinator."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The leader of the group."); v[3] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group coordinator."); v[4] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("members", v, ""); v[5] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[7]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.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.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no error."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation ID of the group."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("protocol_name", v, "The group protocol selected by the coordinator."); v[3] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The leader of the group."); v[4] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group coordinator."); v[5] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("members", v, ""); v[6] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = ; = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[7]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.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.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The error code, or 0 if there was no error."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation ID of the group."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("protocol_name", v, "The group protocol selected by the coordinator."); v[3] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("leader", v, "The leader of the group."); v[4] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group coordinator."); v[5] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v =