public class org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.Message, org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element
{
private java.lang.String name;
private int numPartitions;
private short replicationFactor;
private org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments;
private org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs;
private java.util.List _unknownTaggedFields;
private int next;
private int prev;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: void read(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int next> = v;
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
int v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int next> = v;
return;
}
public void <init>()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
int v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name> = "";
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions> = 0;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor> = 0;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: void <init>(int)>(0);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments> = v;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: void <init>(int)>(0);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int next> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
return 5;
}
public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment v, v;
short v, v, v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
java.lang.RuntimeException v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
if v <= 5 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t read version \u of CreatableTopic");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.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 name 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 name had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor> = v;
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field assignments was serialized as null");
throw v;
label:
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field assignments was serialized as null");
throw v;
label:
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments> = v;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.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 configs was serialized as null");
throw v;
label:
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.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 configs was serialized as null");
throw v;
label:
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs> = v;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields> = null;
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v;
org.apache.kafkaesqueesque.common.protocol.Writable v;
org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v, v, v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 5 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t write version \u of CreatableTopic");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 5 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: void write(org.apache.kafkaesqueesque.common.protocol.Writable,org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: void write(org.apache.kafkaesqueesque.common.protocol.Writable,org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: void write(org.apache.kafkaesqueesque.common.protocol.Writable,org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: int size()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: void write(org.apache.kafkaesqueesque.common.protocol.Writable,org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 5 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesqueesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
java.lang.Integer v;
java.lang.Short v;
boolean v, v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v;
java.lang.Object[] v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment v;
java.util.ArrayList v;
short v, v;
int v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v, v;
java.lang.String v, v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v, v;
java.lang.Object v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 5 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t read version \u of CreatableTopic");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields> = null;
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("name");
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("num_partitions");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Short getShort(java.lang.String)>("replication_factor");
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("assignments");
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection;
v = lengthof v;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("configs");
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection;
v = lengthof v;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
v = v + 1;
goto label;
label:
if v < 5 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: 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.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
java.lang.Integer v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Short v;
boolean v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v, v, v;
short v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct[] v, v;
int v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v, v;
java.lang.String v, v;
java.util.Iterator v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v, v;
java.util.TreeMap v, v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: short;
if v <= 5 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t write version \u of CreatableTopic");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
if v < 5 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("name", v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("num_partitions", v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("replication_factor", v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: int size()>();
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("assignments", v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: int size()>();
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("configs", v);
if v < 5 goto label;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v, v, v;
short v;
java.nio.charset.Charset 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;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v, v;
java.lang.String v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 5 goto label;
v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t size version \u of CreatableTopic");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
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)>("\'name\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 5 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.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 + 2;
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
goto label;
label:
v = 4;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: 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.kafkaesqueesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 5 goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
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()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
int v, v;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
return v;
}
public java.lang.String toString()
{
java.util.Iterator v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v;
short v;
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v;
java.lang.String v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,short,java.lang.String,java.lang.String)>(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[])>("CreatableTopic(name=\u, numPartitions=\u, replicationFactor=\u, assignments=\u, configs=\u)");
return v;
}
public java.lang.String name()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name>;
return v;
}
public int numPartitions()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions>;
return v;
}
public short replicationFactor()
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor>;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments>;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs>;
return v;
}
public int next()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int next>;
return v;
}
public int prev()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int prev>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: 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.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic setName(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: java.lang.String name> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic setNumPartitions(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int numPartitions> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic setReplicationFactor(short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: short replicationFactor> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic setAssignments(org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection)
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection assignments> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic setConfigs(org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection)
{
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection configs> = v;
return v;
}
public void setNext(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int next> = v;
return;
}
public void setPrev(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: int prev> = v;
return;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf v, v;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.ArrayOf v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
java.lang.Object[] v;
org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("name", v, "The topic name.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("num_partitions", v, "The number of partitions to create in the topic, or -1 if we are either specifying a manual partition assignment or using the default partitions.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replication_factor", v, "The number of replicas to create for each partition in the topic, or -1 if we are either specifying a manual partition assignment or using the default replication factor.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "The manual partition assignment, or the empty array if we are using automatic assignment.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("configs", v, "The custom topic configurations to set.");
v[4] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[6];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("name", v, "The topic name.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("num_partitions", v, "The number of partitions to create in the topic, or -1 if we are either specifying a manual partition assignment or using the default partitions.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replication_factor", v, "The number of replicas to create for each partition in the topic, or -1 if we are either specifying a manual partition assignment or using the default replication factor.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableReplicaAssignment: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("assignments", v, "The manual partition assignment, or the empty array if we are using automatic assignment.");
v[3] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreateableTopicConfig: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("configs", v, "The custom topic configurations to set.");
v[4] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[5] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5> = v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[6];
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
<org.apache.kafkaesqueesque.common.message.CreateTopicsRequestData$CreatableTopic: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}