public class org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.Message, org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element
{
private java.lang.String name;
private short errorCode;
private java.lang.String errorMessage;
private short topicConfigErrorCode;
private int numPartitions;
private short replicationFactor;
private java.util.List 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.protocol.Readable v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
int v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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.CreateTopicsResponseData$CreatableTopicResult: void read(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int next> = v;
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
int v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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.CreateTopicsResponseData$CreatableTopicResult: void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int next> = v;
return;
}
public void <init>()
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
int v, v, v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name> = "";
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short errorCode> = 0;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = "";
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = 0;
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
v = (short) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int prev> = v;
v = (int) -2;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int next> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
return 5;
}
public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v;
java.util.ArrayList v, v;
short v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.lang.RuntimeException v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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 CreatableTopicResult");
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.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short errorCode> = v;
if v < 1 goto 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.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = 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 errorMessage 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.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = "";
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = 0;
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
label:
if v < 5 goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = v;
goto label;
label:
v = (short) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = 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.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = null;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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)
{
case 0: goto label;
default: goto label;
};
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = v;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: java.util.List _unknownTaggedFields> = v;
label:
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, v;
boolean v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
java.util.List v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Writable v;
org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v;
short v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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 CreatableTopicResult");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: short errorCode>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
if v < 1 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
if v != null goto label;
if v < 5 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = (short) -1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
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);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
if v == 0 goto label;
v = 1;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
if v != null goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs: 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.CreateTopicsResponseData$CreatableTopicResult: 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 = v + v;
if v < 5 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
if v == 0 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(0);
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(2);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeShort(short)>(v);
label:
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, v, v;
java.lang.Short v, v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v;
java.lang.Object[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.util.ArrayList v, v, v;
short v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v;
java.util.Iterator v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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 CreatableTopicResult");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Short getShort(java.lang.String)>("error_code");
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short errorCode> = v;
if v < 1 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("error_message");
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = "";
label:
if v < 5 goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.NavigableMap: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.NavigableMap: java.lang.Object remove(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = v;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = 0;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = 0;
label:
if v < 5 goto label;
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.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
goto label;
label:
v = (int) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
label:
if v < 5 goto label;
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.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = v;
goto label;
label:
v = (short) -1;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = v;
label:
if v < 5 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("configs");
if v != null goto label;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = null;
goto label;
label:
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = new org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
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.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: 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, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Short v, v, v;
boolean v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v, v;
short v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct[] v;
int v, v, v, v;
java.lang.String v, v, v;
java.util.Iterator v;
java.util.TreeMap v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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 CreatableTopicResult");
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.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: short errorCode>;
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)>("error_code", v);
if v < 1 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("error_message", v);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
if v == 0 goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<java.util.TreeMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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);
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
if v != null 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)>("configs", null);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v;
v = v + 1;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs: 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);
label:
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, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v;
short v, v;
java.lang.String v, v, v, v, v, v, v;
java.lang.RuntimeException v, v;
boolean v, v;
java.util.List v, v, v, v, v, v;
java.nio.charset.Charset v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
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 CreatableTopicResult");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: 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 + 2;
if v < 1 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
if v != null goto label;
if v < 5 goto label;
v = v + 1;
goto label;
label:
v = v + 2;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
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)>("\'errorMessage\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
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 = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
if v == 0 goto label;
v = 1;
v = v + 1;
v = v + 1;
v = v + 2;
label:
if v < 5 goto label;
v = v + 4;
if v < 5 goto label;
v = v + 2;
if v < 5 goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
if v != null goto label;
v = v + 1;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
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.message.CreateTopicsResponseData$CreatableTopicConfigs: int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + v;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult v;
int v, v;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = 0 + v;
return v;
}
public java.lang.String toString()
{
short v, v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
java.util.List v, v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: short errorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
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.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor>;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,short,java.lang.String,short,int,short,java.lang.String)>(v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("CreatableTopicResult(name=\u, errorCode=\u, errorMessage=\u, topicConfigErrorCode=\u, numPartitions=\u, replicationFactor=\u, configs=\u)");
return v;
}
public java.lang.String name()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name>;
return v;
}
public short errorCode()
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short errorCode>;
return v;
}
public java.lang.String errorMessage()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage>;
return v;
}
public short topicConfigErrorCode()
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode>;
return v;
}
public int numPartitions()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions>;
return v;
}
public short replicationFactor()
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor>;
return v;
}
public java.util.List configs()
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs>;
return v;
}
public int next()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int next>;
return v;
}
public int prev()
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int prev>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setName(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String name> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setErrorCode(short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short errorCode> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setErrorMessage(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.lang.String errorMessage> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setTopicConfigErrorCode(short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short topicConfigErrorCode> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setNumPartitions(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int numPartitions> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setReplicationFactor(short)
{
short v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: short;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: short replicationFactor> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult setConfigs(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: java.util.List configs> = v;
return v;
}
public void setNext(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int next> = v;
return;
}
public void setPrev(int)
{
int v;
org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult v;
v := @this: org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: int prev> = v;
return;
}
static void <clinit>()
{
java.lang.Integer v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf v;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, 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, v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
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 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)>("error_code", v, "The error code, or 0 if there was no error.");
v[1] = 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.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[3];
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 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)>("error_code", v, "The error code, or 0 if there was no error.");
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 NULLABLE_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)>("error_message", v, "The error message, or null if there was no error.");
v[2] = 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.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3> = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: 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)[7];
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 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)>("error_code", v, "The error code, or 0 if there was no error.");
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 COMPACT_NULLABLE_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)>("error_message", v, "The error message, or null if there was no error.");
v[2] = 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, "Number of partitions of the topic.");
v[3] = 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, "Replicator factor of the topic.");
v[4] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicConfigs: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf nullable(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, "Configuration of the topic.");
v[5] = v;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
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 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)>("topic_config_error_code", v, "Optional topic config error returned if configs are not returned in the response.");
v[1] = v;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[6] = 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.CreateTopicsResponseData$CreatableTopicResult: 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.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
<org.apache.kafkaesqueesque.common.message.CreateTopicsResponseData$CreatableTopicResult: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}