public class org.apache.kafkaesque.common.message.JoinGroupRequestData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage { private java.lang.String groupId; private int sessionTimeoutMs; private int rebalanceTimeoutMs; private java.lang.String memberId; private java.lang.String groupInstanceId; private java.lang.String protocolType; private org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection protocols; 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.protocol.Readable v; short v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.protocol.types.Struct v; short v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.JoinGroupRequestData$JoinGroupRequestProtocolCollection v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; specialinvoke v.()>(); v. = ""; v. = 0; v = (int) -1; v. = v; v. = ""; v. = null; v. = ""; v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection; specialinvoke v.(int)>(0); v. = v; return; } public short apiKey() { org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; return 11; } public short lowestSupportedVersion() { org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; return 7; } public void read(org.apache.kafkaesque.common.protocol.Readable, short) { org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v; java.util.List 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, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocol v, v; java.lang.RuntimeException v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; org.apache.kafkaesque.common.protocol.Readable v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.Readable; v := @parameter: short; 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 groupId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field groupId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; v = interfaceinvoke v.(); v. = v; if v < 1 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v = (int) -1; 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 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 < 5 goto 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. = null; goto label; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field groupInstanceId 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; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field protocolType was serialized as null"); throw v; 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; 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 protocols was serialized as null"); throw v; label: v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocol; 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 protocols was serialized as null"); throw v; label: v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocol; 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; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v, v, v; boolean v, v; org.apache.kafkaesque.common.protocol.Writable v; java.util.List v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v; short v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; java.util.Iterator v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; java.lang.Object v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; 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.; interfaceinvoke v.(v); if v < 1 goto label; v = v.; 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); if v < 5 goto label; v = v.; if v != null goto label; if v < 6 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 < 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); goto label; label: v = v.; if v == null goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default groupInstanceId at version \u0001"); specialinvoke v.(java.lang.String)>(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); if v < 6 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: 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; java.lang.Integer v, v; java.util.ArrayList v; short v; int v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v; java.lang.String v, v, v, v; boolean v, v; java.util.Iterator v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocol v; java.util.Set v; org.apache.kafkaesque.common.protocol.types.Struct v; java.util.List v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; java.lang.Object v, v, v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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: v = virtualinvoke v.("group_id"); v. = v; v = virtualinvoke v.("session_timeout_ms"); v = virtualinvoke v.(); v. = v; if v < 1 goto label; v = virtualinvoke v.("rebalance_timeout_ms"); v = virtualinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: v = virtualinvoke v.("member_id"); v. = v; if v < 5 goto label; v = virtualinvoke v.("group_instance_id"); v. = v; goto label; label: v. = null; label: v = virtualinvoke v.("protocol_type"); v. = v; v = virtualinvoke v.("protocols"); v = new org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection; 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.JoinGroupRequestData$JoinGroupRequestProtocol; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v); virtualinvoke 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; int v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v; java.lang.String v, v, v, v, v, v; boolean v; java.util.Iterator v; org.apache.kafkaesque.common.errors.UnsupportedVersionException 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.TreeMap v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; java.lang.Object v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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); v = v.; virtualinvoke v.("group_id", v); v = v.; v = staticinvoke (v); virtualinvoke v.("session_timeout_ms", v); if v < 1 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("rebalance_timeout_ms", v); label: v = v.; virtualinvoke v.("member_id", v); if v < 5 goto label; v = v.; virtualinvoke v.("group_instance_id", v); goto label; label: v = v.; if v == null goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default groupInstanceId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; virtualinvoke v.("protocol_type", v); v = v.; v = virtualinvoke v.(); v = newarray (org.apache.kafkaesque.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.("protocols", 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.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; short v; java.lang.String 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; 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.JoinGroupRequestData v; java.lang.Object v, v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; 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)>("\'groupId\' 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 = 0 + v; goto label; label: v = lengthof v; v = v + 2; v = 0 + v; label: v = v + 4; if v < 1 goto label; v = v + 4; 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 < 5 goto 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)>("\'groupInstanceId\' 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)>("\'protocolType\' 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 = 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; 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) { org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v, v, v; boolean v, v, v, v, 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.JoinGroupRequestData v; java.lang.Object v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.; 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: return 1; } public int hashCode() { int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.; 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; return v; } public java.lang.String toString() { int v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection 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; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.; 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 = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v) ("JoinGroupRequestData(groupId=\u, sessionTimeoutMs=\u, rebalanceTimeoutMs=\u, memberId=\u, groupInstanceId=\u, protocolType=\u, protocols=\u)"); return v; } public java.lang.String groupId() { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public int sessionTimeoutMs() { int v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public int rebalanceTimeoutMs() { int v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public java.lang.String memberId() { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public java.lang.String groupInstanceId() { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public java.lang.String protocolType() { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection protocols() { org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; java.util.ArrayList v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; 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.JoinGroupRequestData setGroupId(java.lang.String) { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setSessionTimeoutMs(int) { int v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setRebalanceTimeoutMs(int) { int v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setMemberId(java.lang.String) { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setGroupInstanceId(java.lang.String) { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setProtocolType(java.lang.String) { java.lang.String v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesque.common.message.JoinGroupRequestData setProtocols(org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection) { org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection v; org.apache.kafkaesque.common.message.JoinGroupRequestData v; v := @this: org.apache.kafkaesque.common.message.JoinGroupRequestData; v := @parameter: org.apache.kafkaesque.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection; v. = v; return v; } static void () { org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v; java.lang.Object[] 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; org.apache.kafkaesque.common.protocol.types.CompactArrayOf 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; 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; org.apache.kafkaesque.common.protocol.types.Schema[] v; org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection 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)[5]; 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)>("group_id", v, "The group identifier."); 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)>("session_timeout_ms", v, "The coordinator considers the consumer dead if it receives no heartbeat after this timeout in milliseconds."); 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)>("member_id", v, "The member id assigned by the group 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)>("protocol_type", v, "The unique name the for class of protocols implemented by the group we want to join."); v[3] = 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)>("protocols", v, "The list of protocols that the member supports."); v[4] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(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)>("group_id", v, "The group identifier."); 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)>("session_timeout_ms", v, "The coordinator considers the consumer dead if it receives no heartbeat after this timeout in milliseconds."); 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)>("rebalance_timeout_ms", v, "The maximum time in milliseconds that the coordinator will wait for each member to rejoin when rebalancing 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)>("member_id", v, "The member id assigned by the group 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)>("protocol_type", v, "The unique name the for class of protocols implemented by the group we want to join."); 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)>("protocols", v, "The list of protocols that the member supports."); v[5] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; 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)>("group_id", v, "The group identifier."); 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)>("session_timeout_ms", v, "The coordinator considers the consumer dead if it receives no heartbeat after this timeout in milliseconds."); 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)>("rebalance_timeout_ms", v, "The maximum time in milliseconds that the coordinator will wait for each member to rejoin when rebalancing 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)>("member_id", v, "The member id assigned by the group 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)>("group_instance_id", v, "The unique identifier of the consumer instance provided by end user."); 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)>("protocol_type", v, "The unique name the for class of protocols implemented by the group we want to join."); 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)>("protocols", v, "The list of protocols that the member supports."); v[6] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[8]; 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)>("group_id", v, "The group identifier."); 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)>("session_timeout_ms", v, "The coordinator considers the consumer dead if it receives no heartbeat after this timeout in milliseconds."); 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)>("rebalance_timeout_ms", v, "The maximum time in milliseconds that the coordinator will wait for each member to rejoin when rebalancing 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)>("member_id", v, "The member id assigned by the group 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)>("group_instance_id", v, "The unique identifier of the consumer instance provided by end user."); v[4] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.