public class org.apache.kafkaesqueesque.common.message.FetchRequestData extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.ApiMessage { private int replicaId; private int maxWait; private int minBytes; private int maxBytes; private byte isolationLevel; private int sessionId; private int epoch; private java.util.List topics; private java.util.List forgotten; private java.lang.String rackId; private java.util.List _unknownTaggedFields; 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 SCHEMA_6; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_7; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_8; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_9; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_10; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_11; public static final org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesqueesque.common.protocol.Readable, short) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; short v; org.apache.kafkaesqueesque.common.protocol.Readable v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesqueesque.common.protocol.types.Struct, short) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; short v; org.apache.kafkaesqueesque.common.protocol.types.Struct v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { org.apache.kafkaesqueesque.common.message.FetchRequestData v; int v; java.util.ArrayList v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; specialinvoke v.()>(); v. = 0; v. = 0; v. = 0; v. = 2147483647; v. = 0; v. = 0; v = (int) -1; v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = ""; return; } public short apiKey() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; return 1; } public short lowestSupportedVersion() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; return 11; } public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short) { java.util.ArrayList v, v, v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; short v, v; byte v; org.apache.kafkaesqueesque.common.protocol.Readable v; int v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.message.FetchRequestData$ForgottenTopic v; java.lang.String v, v; org.apache.kafkaesqueesque.common.message.FetchRequestData$FetchableTopic v; java.lang.RuntimeException v, v, v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable; v := @parameter: short; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; if v < 3 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = 2147483647; label: if v < 4 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = 0; label: if v < 7 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = 0; label: if v < 7 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field topics was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.FetchRequestData$FetchableTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; if v < 7 goto label; v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field forgotten was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesqueesque.common.message.FetchRequestData$ForgottenTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 11 goto label; v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field rackId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field rackId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; goto label; label: v. = ""; label: v. = null; return; } public void write(org.apache.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v, v; boolean v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v, v, v, v; java.util.List v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.Writable v; org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v; short v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); if v < 3 goto label; v = v.; interfaceinvoke v.(v); label: if v < 4 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default isolationLevel at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 7 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default sessionId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 7 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = (int) -1; if v == v goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default epoch at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: if v < 7 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default forgotten at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 11 goto label; v = v.; v = virtualinvoke v.(v); v = lengthof v; interfaceinvoke v.(v); interfaceinvoke v.(v); label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = 0 + v; if v <= 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(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, v, v, v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v; org.apache.kafkaesqueesque.common.message.FetchRequestData$ForgottenTopic v; org.apache.kafkaesqueesque.common.message.FetchRequestData$FetchableTopic v; java.util.List v, v; java.lang.Object[] v, v; org.apache.kafkaesqueesque.common.protocol.types.Struct v; java.util.ArrayList v, v, v; short v; int v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v; java.lang.Object v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct; v := @parameter: short; v. = null; v = virtualinvoke v.("replica_id"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("max_wait"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("min_bytes"); v = virtualinvoke v.(); v. = v; if v < 3 goto label; v = virtualinvoke v.("max_bytes"); v = virtualinvoke v.(); v. = v; goto label; label: v. = 2147483647; label: if v < 4 goto label; v = virtualinvoke v.("isolation_level"); v. = v; goto label; label: v. = 0; label: if v < 7 goto label; v = virtualinvoke v.("session_id"); v = virtualinvoke v.(); v. = v; goto label; label: v. = 0; label: if v < 7 goto label; v = virtualinvoke v.("epoch"); v = virtualinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: v = virtualinvoke v.("topics"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = new org.apache.kafkaesqueesque.common.message.FetchRequestData$FetchableTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: if v < 7 goto label; v = virtualinvoke v.("forgotten"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = new org.apache.kafkaesqueesque.common.message.FetchRequestData$ForgottenTopic; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 11 goto label; v = virtualinvoke v.("rack_id"); v. = v; goto label; label: v. = ""; label: return; } public org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short) { java.lang.Integer v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v, v; java.lang.Byte v; boolean v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v, v, v, v; java.util.List v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema[] v; org.apache.kafkaesqueesque.common.protocol.types.Struct v, v, v; short v; org.apache.kafkaesqueesque.common.protocol.types.Struct[] v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: short; v = new org.apache.kafkaesqueesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v); v = v.; v = staticinvoke (v); virtualinvoke v.("replica_id", v); v = v.; v = staticinvoke (v); virtualinvoke v.("max_wait", v); v = v.; v = staticinvoke (v); virtualinvoke v.("min_bytes", v); if v < 3 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("max_bytes", v); label: if v < 4 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("isolation_level", v); goto label; label: v = v.; if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default isolationLevel at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 7 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("session_id", v); goto label; label: v = v.; if v == 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default sessionId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 7 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("epoch", v); goto label; label: v = v.; v = (int) -1; if v == v goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default epoch at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("topics", v); if v < 7 goto label; v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("forgotten", v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default forgotten at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 11 goto label; v = v.; virtualinvoke v.("rack_id", v); label: return v; } public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; boolean v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v; java.util.List v, v, 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; java.lang.String v, v, v; org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v; java.util.Iterator v, v, v; java.lang.RuntimeException v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; v = 12; if v < 3 goto label; v = 16; label: if v < 4 goto label; v = v + 1; label: if v < 7 goto label; v = v + 4; if v < 7 goto label; v = v + 4; label: v = 4; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; if v < 7 goto label; v = 4; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; label: if v < 11 goto label; v = v.; v = ; v = virtualinvoke v.(v); v = lengthof v; if v <= 32767 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("\'rackId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); v = lengthof v; v = v + 2; v = v + v; label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = 0 + v; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = v + v; goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } public boolean equals(java.lang.Object) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v, v; boolean v, v, v, v; java.util.List v, 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; java.lang.Object v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesqueesque.common.message.FetchRequestData; if v != 0 goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; return 0; label: return 1; } public int hashCode() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v; java.util.List v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; v = 0 + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = v + v; return v; } public java.lang.String toString() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v; int v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; java.util.Iterator v, v; java.util.List v, v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v, v, v, v) ("FetchRequestData(replicaId=\u, maxWait=\u, minBytes=\u, maxBytes=\u, isolationLevel=\u, sessionId=\u, epoch=\u, topics=\u, forgotten=\u, rackId=\u)"); return v; } public int replicaId() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public int maxWait() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public int minBytes() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public int maxBytes() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public byte isolationLevel() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public int sessionId() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public int epoch() { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public java.util.List topics() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.util.List v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public java.util.List forgotten() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.util.List v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public java.lang.String rackId() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.lang.String v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; return v; } public java.util.List unknownTaggedFields() { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.util.List v, v; java.util.ArrayList v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v = v.; if v != null goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(0); v. = v; label: v = v.; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setReplicaId(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setMaxWait(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setMinBytes(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setMaxBytes(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setIsolationLevel(byte) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; byte v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: byte; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setSessionId(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setEpoch(int) { int v; org.apache.kafkaesqueesque.common.message.FetchRequestData v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setTopics(java.util.List) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.util.List v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setForgotten(java.util.List) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.util.List v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesqueesque.common.message.FetchRequestData setRackId(java.lang.String) { org.apache.kafkaesqueesque.common.message.FetchRequestData v; java.lang.String v; v := @this: org.apache.kafkaesqueesque.common.message.FetchRequestData; v := @parameter: java.lang.String; v. = v; return v; } static void () { org.apache.kafkaesqueesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.types.Schema[] v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the follower, of -1 if this request is from a consumer."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_wait", v, "The maximum time in milliseconds to wait for the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("min_bytes", v, "The minimum bytes to accumulate in the response."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to fetch."); v[3] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the follower, of -1 if this request is from a consumer."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_wait", v, "The maximum time in milliseconds to wait for the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("min_bytes", v, "The minimum bytes to accumulate in the response."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_bytes", v, "The maximum bytes to fetch. See KIP-74 for cases where this limit may not be honored."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to fetch."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = 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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the follower, of -1 if this request is from a consumer."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_wait", v, "The maximum time in milliseconds to wait for the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("min_bytes", v, "The minimum bytes to accumulate in the response."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_bytes", v, "The maximum bytes to fetch. See KIP-74 for cases where this limit may not be honored."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("isolation_level", v, "This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records"); v[4] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to fetch."); v[5] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = 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 = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the follower, of -1 if this request is from a consumer."); v[0] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_wait", v, "The maximum time in milliseconds to wait for the response."); v[1] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("min_bytes", v, "The minimum bytes to accumulate in the response."); v[2] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("max_bytes", v, "The maximum bytes to fetch. See KIP-74 for cases where this limit may not be honored."); v[3] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("isolation_level", v, "This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records"); v[4] = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "The topics to fetch."); v[5] = v; specialinvoke v.(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = new org.apache.kafkaesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[9]; v = new org.apache.kafkaesqueesque.common.protocol.types.Field; v = ; specialinvoke v.