public class org.apache.kafkaesque.common.message.OffsetCommitRequestData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage
{
private java.lang.String groupId;
private int generationId;
private java.lang.String memberId;
private java.lang.String groupInstanceId;
private long retentionTimeMs;
private java.util.List topics;
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 SCHEMA_8;
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.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
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.OffsetCommitRequestData: 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.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
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.OffsetCommitRequestData: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
int v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId> = "";
v = (int) -1;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId> = "";
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId> = null;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = -1L;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics> = v;
return;
}
public short apiKey()
{
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
return 8;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
return 8;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic v, v;
java.util.List v, v;
long 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;
java.lang.String v, v, v, v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.lang.RuntimeException v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
if v < 8 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 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.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId> = v;
if v < 1 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
label:
if v < 1 goto label;
if v < 8 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.OffsetCommitRequestData: java.lang.String memberId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId> = "";
label:
if v < 7 goto label;
if v < 8 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.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId> = null;
label:
if v < 2 goto label;
if v > 4 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = -1L;
label:
if v < 8 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.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 topics 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.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic;
specialinvoke v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: void <init>(org.apache.kafkaesque.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.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.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 topics 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.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic;
specialinvoke v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: void <init>(org.apache.kafkaesque.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.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics> = v;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List _unknownTaggedFields> = null;
if v < 8 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.OffsetCommitRequestData: 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.OffsetCommitRequestData: 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;
boolean v, v;
org.apache.kafkaesque.common.protocol.Writable v;
java.util.List v, v, v, v, v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v;
long v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.Iterator v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 8 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 < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 8 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);
label:
if v < 7 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 8 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.OffsetCommitRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 8 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.OffsetCommitRequestData: 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 < 2 goto label;
if v > 4 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeLong(long)>(v);
label:
if v < 8 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
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.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: void write(org.apache.kafkaesque.common.protocol.Writable,org.apache.kafkaesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
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.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: void write(org.apache.kafkaesque.common.protocol.Writable,org.apache.kafkaesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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 < 8 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)
{
java.lang.Object[] v;
long v;
java.lang.Integer v;
java.util.ArrayList v, v;
short v;
java.lang.Long v;
int v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
boolean v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic v;
java.util.Set v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List _unknownTaggedFields> = null;
if v < 8 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)>("group_id");
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId> = v;
if v < 1 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("generation_id");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
label:
if v < 1 goto 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.OffsetCommitRequestData: java.lang.String memberId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId> = "";
label:
if v < 7 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.OffsetCommitRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId> = null;
label:
if v < 2 goto label;
if v > 4 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("retention_time_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = -1L;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("topics");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = new org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic;
specialinvoke v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: void <init>(org.apache.kafkaesque.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 < 8 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.OffsetCommitRequestData: 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.OffsetCommitRequestData: 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)
{
long v;
java.lang.Integer v;
org.apache.kafkaesque.common.protocol.types.Schema v;
short v;
java.lang.Long v;
int v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
boolean v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Struct[] v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
java.util.List v, v;
java.util.TreeMap v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: short;
v = null;
if v < 8 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.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String groupId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("group_id", v);
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("generation_id", v);
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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);
label:
if v < 7 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: 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 < 2 goto label;
if v > 4 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("retention_time_ms", v);
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
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.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("topics", v);
if v < 8 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;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
short v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.lang.RuntimeException v, v, v;
boolean v, v;
java.util.List v, v, v, v, v;
java.nio.charset.Charset 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;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.Iterator v, v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 8 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 < 1 goto label;
v = v + 4;
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 8 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:
if v < 7 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 8 goto label;
v = v + 1;
goto label;
label:
v = v + 2;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 8 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:
if v < 2 goto label;
if v > 4 goto label;
v = v + 8;
label:
if v < 8 goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
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.message.OffsetCommitRequestData$OffsetCommitRequestTopic: int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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 < 8 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)
{
long v, v;
byte v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
boolean v, v, v, v, v;
java.util.List v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.OffsetCommitRequestData;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: long retentionTimeMs>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
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()
{
long v, v, v;
int 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;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.List v, v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: long retentionTimeMs>;
v = v >> 32;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
long v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.Iterator v;
java.util.List v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: long retentionTimeMs>;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesque.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,long,java.lang.String)>(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[])>("OffsetCommitRequestData(groupId=\u, generationId=\u, memberId=\u, groupInstanceId=\u, retentionTimeMs=\u, topics=\u)");
return v;
}
public java.lang.String groupId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId>;
return v;
}
public int generationId()
{
int v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId>;
return v;
}
public java.lang.String memberId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId>;
return v;
}
public java.lang.String groupInstanceId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId>;
return v;
}
public long retentionTimeMs()
{
long v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs>;
return v;
}
public java.util.List topics()
{
java.util.List v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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.OffsetCommitRequestData: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setGroupId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupId> = v;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setGenerationId(int)
{
int v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: int;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: int generationId> = v;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setMemberId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String memberId> = v;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setGroupInstanceId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.lang.String groupInstanceId> = v;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setRetentionTimeMs(long)
{
long v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: long;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: long retentionTimeMs> = v;
return v;
}
public org.apache.kafkaesque.common.message.OffsetCommitRequestData setTopics(java.util.List)
{
java.util.List v;
org.apache.kafkaesque.common.message.OffsetCommitRequestData v;
v := @this: org.apache.kafkaesque.common.message.OffsetCommitRequestData;
v := @parameter: java.util.List;
v.<org.apache.kafkaesque.common.message.OffsetCommitRequestData: java.util.List topics> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v, v, v, v;
java.lang.Object[] v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.CompactArrayOf v;
org.apache.kafkaesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v, v, v, 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)>("group_id", v, "The unique group identifier.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = 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 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_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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 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 member ID assigned by the group coordinator.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[5];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <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)>("group_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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 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 member ID assigned by the group coordinator.");
v[2] = 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 INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("retention_time_ms", v, "The time period in ms to retain the offset.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
v[4] = 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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3> = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
<org.apache.kafkaesque.common.message.OffsetCommitRequestData: 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)[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 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_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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 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 member ID assigned by the group coordinator.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
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.OffsetCommitRequestData: 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 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_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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 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 member ID assigned by the group coordinator.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[5];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <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)>("group_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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 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 member ID assigned by the group coordinator.");
v[2] = 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[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
v[4] = 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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_7> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[6];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <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)>("group_id", v, "The unique group identifier.");
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 INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("generation_id", v, "The generation of the group.");
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_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 member ID assigned by the group coordinator.");
v[2] = 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[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to commit offsets for.");
v[4] = 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[5] = 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.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_8> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[9];
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_6>;
v[6] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_7>;
v[7] = v;
v = <org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_8>;
v[8] = v;
<org.apache.kafkaesque.common.message.OffsetCommitRequestData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}