public class org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember extends java.lang.Object implements org.apache.kafkaesque.common.protocol.Message
{
private java.lang.String memberId;
private java.lang.String groupInstanceId;
private byte[] metadata;
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 <init>(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.protocol.Readable v;
short v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: void read(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId> = "";
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = null;
v = <org.apache.kafkaesque.common.utils.Bytes: byte[] EMPTY>;
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
return 7;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
short v, v, v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.lang.RuntimeException v, v, v, v;
java.util.List v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
if v <= 7 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t read version \u of JoinGroupResponseMember");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 6 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(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" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("string field memberId had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId> = v;
if v < 5 goto label;
if v < 6 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = null;
goto label;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("string field groupInstanceId had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = null;
label:
if v < 6 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field metadata was serialized as null");
throw v;
label:
v = newarray (byte)[v];
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: void readArray(byte[])>(v);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata> = v;
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields> = null;
if v < 6 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields> = 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, 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;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v, v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 7 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t write version \u of JoinGroupResponseMember");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 6 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
if v < 5 goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 6 goto label;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = (short) -1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 6 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v == null goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Attempted to write a non-default groupInstanceId at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 6 goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 6 goto label;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
java.util.ArrayList v;
short v;
int v;
java.lang.String v, v, v;
boolean v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.util.Set v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 7 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t read version \u of JoinGroupResponseMember");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields> = null;
if v < 6 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("member_id");
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId> = v;
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("group_instance_id");
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = null;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte[] getByteArray(java.lang.String)>("metadata");
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata> = v;
if v < 6 goto label;
v = interfaceinvoke v.<java.util.NavigableMap: boolean isEmpty()>();
if v != 0 goto label;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.NavigableMap: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields> = v;
v = interfaceinvoke v.<java.util.NavigableMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Schema v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
java.util.TreeMap v, v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: short;
if v <= 7 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t write version \u of JoinGroupResponseMember");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
if v < 6 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("member_id", v);
if v < 5 goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("group_instance_id", v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v == null goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Attempted to write a non-default groupInstanceId at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setByteArray(java.lang.String,byte[])>("metadata", v);
if v < 6 goto label;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v, v;
boolean v;
java.util.List v, v, v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
short v;
java.nio.charset.Charset 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;
java.lang.String v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
java.lang.RuntimeException v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 7 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t size version \u of JoinGroupResponseMember");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'memberId\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 6 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = 0 + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = 0 + v;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 6 goto label;
v = v + 1;
goto label;
label:
v = v + 2;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'groupInstanceId\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 6 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = lengthof v;
if v < 6 goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
v = v + 4;
label:
v = v + v;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 6 goto label;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
byte[] v, v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = staticinvoke <java.util.Arrays: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = staticinvoke <java.util.Arrays: int hashCode(byte[])>(v);
v = v + v;
return v;
}
public java.lang.String toString()
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
v = staticinvoke <java.util.Arrays: java.lang.String toString(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("JoinGroupResponseMember(memberId=\u, groupInstanceId=\u, metadata=\u)");
return v;
}
public java.lang.String memberId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId>;
return v;
}
public java.lang.String groupInstanceId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId>;
return v;
}
public byte[] metadata()
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember setMemberId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String memberId> = v;
return v;
}
public org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember setGroupInstanceId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: java.lang.String groupInstanceId> = v;
return v;
}
public org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember setMetadata(byte[])
{
byte[] v;
org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember v;
v := @this: org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember;
v := @parameter: byte[];
v.<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: byte[] metadata> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.Field 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;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v;
java.lang.Object[] v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType 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)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The group member ID.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType BYTES>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("metadata", v, "The group member metadata.");
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3> = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[3];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The group member ID.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(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[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType BYTES>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("metadata", v, "The group member metadata.");
v[2] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The group member ID.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(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[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_BYTES>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("metadata", v, "The group member metadata.");
v[2] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[3] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6> = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6>;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_7> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[8];
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6>;
v[6] = v;
v = <org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_7>;
v[7] = v;
<org.apache.kafkaesque.common.message.JoinGroupResponseData$JoinGroupResponseMember: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}