public class org.apache.kafkaesque.common.message.HeartbeatRequestData 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 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[] 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.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
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.HeartbeatRequestData: 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.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
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.HeartbeatRequestData: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId> = "";
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId> = 0;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId> = "";
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId> = null;
return;
}
public short apiKey()
{
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
return 12;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
return 4;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
short v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.lang.RuntimeException v, v, v, v, v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
java.util.List v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
if v < 4 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.HeartbeatRequestData: java.lang.String groupId> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId> = v;
if v < 4 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.HeartbeatRequestData: java.lang.String memberId> = v;
if v < 3 goto label;
if v < 4 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.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId> = null;
label:
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.util.List _unknownTaggedFields> = null;
if v < 4 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.HeartbeatRequestData: 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.HeartbeatRequestData: 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;
short v, v;
int 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.errors.UnsupportedVersionException v, v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
org.apache.kafkaesque.common.protocol.Writable v;
java.util.List v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
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.HeartbeatRequestData: java.lang.String groupId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 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);
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 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 < 3 goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
if v < 4 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 4 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Attempted to write a non-default groupInstanceId at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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 < 4 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.Integer v;
java.util.ArrayList v;
short v;
int v, v;
java.lang.String v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.util.List _unknownTaggedFields> = null;
if v < 4 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.HeartbeatRequestData: java.lang.String groupId> = v;
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.HeartbeatRequestData: int generationId> = v;
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.HeartbeatRequestData: java.lang.String memberId> = v;
if v < 3 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.HeartbeatRequestData: java.lang.String groupInstanceId> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId> = null;
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.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: 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)
{
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
java.lang.Integer v;
org.apache.kafkaesque.common.protocol.types.Schema v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
java.util.TreeMap v, v;
int v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
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.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: 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);
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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);
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("member_id", v);
if v < 3 goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: 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 < 4 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;
java.util.List 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;
java.util.Iterator v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupId>;
virtualinvoke v.<org.apache.kafkaesque.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.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:
v = v + 4;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String memberId>;
virtualinvoke v.<org.apache.kafkaesque.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.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 < 3 goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
virtualinvoke v.<org.apache.kafkaesque.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.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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 < 4 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)
{
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.HeartbeatRequestData;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: int generationId>;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: int generationId>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: int generationId>;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.lang.String groupInstanceId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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 = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,java.lang.String,java.lang.String)>(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[])>("HeartbeatRequestData(groupId=\u, generationId=\u, memberId=\u, groupInstanceId=\u)");
return v;
}
public java.lang.String groupId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId>;
return v;
}
public int generationId()
{
int v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId>;
return v;
}
public java.lang.String memberId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId>;
return v;
}
public java.lang.String groupInstanceId()
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: 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.HeartbeatRequestData: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.HeartbeatRequestData setGroupId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupId> = v;
return v;
}
public org.apache.kafkaesque.common.message.HeartbeatRequestData setGenerationId(int)
{
int v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: int;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: int generationId> = v;
return v;
}
public org.apache.kafkaesque.common.message.HeartbeatRequestData setMemberId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String memberId> = v;
return v;
}
public org.apache.kafkaesque.common.message.HeartbeatRequestData setGroupInstanceId(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.HeartbeatRequestData v;
v := @this: org.apache.kafkaesque.common.message.HeartbeatRequestData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.HeartbeatRequestData: java.lang.String groupInstanceId> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.Field 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;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v;
java.lang.Object[] v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[3];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The group id.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType 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.");
v[2] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = 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 group id.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType 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.");
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;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3> = 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 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 group id.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType 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.");
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 = 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[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.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[5];
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
<org.apache.kafkaesque.common.message.HeartbeatRequestData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}