public class org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData extends java.lang.Object implements org.apache.kafkaesqueesqueesque.common.protocol.ApiMessage
{
private java.lang.String groupId;
private int generationId;
private java.lang.String memberId;
private java.lang.String groupInstanceId;
private java.lang.String protocolType;
private java.lang.String protocolName;
private java.util.List assignments;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_5;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
short v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
short v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId> = "";
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId> = 0;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId> = "";
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = null;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = null;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = null;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments> = v;
return;
}
public short apiKey()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
return 14;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
return 5;
}
public void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
java.util.List v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment v, v;
java.util.ArrayList v, v;
short 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, v, v;
java.lang.RuntimeException v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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 groupId 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 groupId had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId> = v;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId> = v;
if v < 3 goto label;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = null;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = 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 protocolType had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = null;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = 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 protocolName had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = null;
label:
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field assignments was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field assignments was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments> = v;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields> = null;
if v < 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable, org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v, v;
org.apache.kafkaesqueesqueesque.common.protocol.Writable v;
boolean v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v, v, v, v, v;
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, v, v, v;
java.util.Iterator v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
if v < 3 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 4 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = (short) -1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeShort(short)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v != null goto label;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v != null goto label;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
label:
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
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()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable,org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
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()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable,org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 4 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesqueesqueesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
java.lang.Object[] v;
java.lang.Integer v;
java.util.ArrayList v, v;
short v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Object v, v, v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields> = null;
if v < 4 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("group_id");
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("generation_id");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("member_id");
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId> = v;
if v < 3 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("group_instance_id");
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = null;
label:
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("protocol_type");
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = null;
label:
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("protocol_name");
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = null;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("assignments");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = new org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
if v < 4 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.protocol.types.Struct toStruct(short)
{
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
java.lang.Integer v;
short v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct[] v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
java.util.Iterator v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v, v;
java.util.TreeMap v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v, v;
java.lang.Object v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: short;
v = null;
if v < 4 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("group_id", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("generation_id", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("member_id", v);
if v < 3 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("group_instance_id", v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("protocol_type", v);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("protocol_name", v);
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
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 = v;
v = v + 1;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("assignments", v);
if v < 4 goto label;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v, v, v;
short v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.RuntimeException v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
boolean v, v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v, v, v, v, v;
java.nio.charset.Charset v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
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)>("\'groupId\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 4 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.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:
v = v + 4;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 4 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.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:
if v < 3 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 4 goto label;
v = v + 1;
goto label;
label:
v = v + 2;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 4 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.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:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v != null goto label;
v = v + 1;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
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)>("\'protocolType\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v != null goto label;
v = v + 1;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
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)>("\'protocolName\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
label:
if v < 4 goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
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.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 4 goto label;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
boolean v, v, v, v, v, v, v;
java.util.List v, v, v, 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, v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
java.util.List 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, v, v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, 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[])>("SyncGroupRequestData(groupId=\u, generationId=\u, memberId=\u, groupInstanceId=\u, protocolType=\u, protocolName=\u, assignments=\u)");
return v;
}
public java.lang.String groupId()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId>;
return v;
}
public int generationId()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId>;
return v;
}
public java.lang.String memberId()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId>;
return v;
}
public java.lang.String groupInstanceId()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId>;
return v;
}
public java.lang.String protocolType()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType>;
return v;
}
public java.lang.String protocolName()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName>;
return v;
}
public java.util.List assignments()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments>;
return v;
}
public java.util.List unknownTaggedFields()
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v, v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: 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.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setGroupId(java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupId> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setGenerationId(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: int generationId> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setMemberId(java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String memberId> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setGroupInstanceId(java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String groupInstanceId> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setProtocolType(java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolType> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setProtocolName(java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.lang.String protocolName> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData setAssignments(java.util.List)
{
org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData v;
java.util.List v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: java.util.List assignments> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf v, v;
java.lang.Object[] v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field[] v, v, v, v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[4];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The unique group identifier.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "Each assignment.");
v[3] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[5];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The unique group identifier.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_instance_id", v, "The unique identifier of the consumer instance provided by end user.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "Each assignment.");
v[4] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[6];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The unique group identifier.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_instance_id", v, "The unique identifier of the consumer instance provided by end user.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "Each assignment.");
v[4] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[5] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[8];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The unique group identifier.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("member_id", v, "The member ID assigned by the group.");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_instance_id", v, "The unique identifier of the consumer instance provided by end user.");
v[3] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("protocol_type", v, "The group protocol type.");
v[4] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType COMPACT_NULLABLE_STRING>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("protocol_name", v, "The group protocol name.");
v[5] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData$SyncGroupRequestAssignment: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "Each assignment.");
v[6] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[7] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_5> = v;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)[6];
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
<org.apache.kafkaesqueesqueesque.common.message.SyncGroupRequestData: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}