public class org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData extends java.lang.Object implements org.apache.kafkaesqueesqueesque.common.protocol.ApiMessage { private java.lang.String transactionalId; private java.lang.String groupId; private long producerId; private short producerEpoch; private int generationId; private java.lang.String memberId; private java.lang.String groupInstanceId; private java.util.List topics; private java.util.List _unknownTaggedFields; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_2; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_3; public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesqueesqueesque.common.protocol.Readable, short) { org.apache.kafkaesqueesqueesque.common.protocol.Readable v; short v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short) { org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v; short v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { int v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; java.util.ArrayList v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; specialinvoke v.()>(); v. = ""; v. = ""; v. = 0L; v. = 0; v = (int) -1; v. = v; v. = ""; v. = null; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; return; } public short apiKey() { org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; return 28; } public short lowestSupportedVersion() { org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; return 3; } public void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short) { org.apache.kafkaesqueesqueesque.common.protocol.Readable v; java.util.List v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v; java.util.ArrayList v, v; short v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic v, v; java.lang.RuntimeException v, v, v, v, v, v, v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable; v := @parameter: short; if v < 3 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field transactionalId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field transactionalId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; if v < 3 goto label; v = interfaceinvoke v.(); v = v - 1; goto label; label: v = interfaceinvoke v.(); v = v; label: if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field groupId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field groupId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(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 = (int) -1; v. = v; label: if v < 3 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field memberId was serialized as null"); throw v; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field memberId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; goto label; label: v. = ""; label: if v < 3 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v. = null; goto label; label: if v <= 32767 goto label; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("string field groupInstanceId had invalid length \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); v. = v; goto label; label: v. = null; label: if v < 3 goto label; v = interfaceinvoke v.(); v = v - 1; 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.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; 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.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; label: v. = null; if v < 3 goto label; v = interfaceinvoke v.(); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); lookupswitch(v) { default: goto label; }; label: v = v.; v = interfaceinvoke v.(v, v, v); v. = v; v = v + 1; goto label; label: return; } public void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable, org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v, v, v, v; org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v, v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.Writable v; boolean v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter v; org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v; java.util.List v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v; short v, 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, v, v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = v.; v = virtualinvoke v.(v); if v < 3 goto label; v = lengthof v; v = v + 1; interfaceinvoke v.(v); goto label; label: v = lengthof v; interfaceinvoke v.(v); label: interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v < 3 goto label; v = lengthof v; v = v + 1; interfaceinvoke v.(v); goto label; label: v = lengthof v; interfaceinvoke v.(v); label: interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); if v < 3 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = (int) -1; if v == v goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default generationId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 3 goto label; v = v.; v = virtualinvoke v.(v); v = lengthof v; v = v + 1; interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(""); if v != 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default memberId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 3 goto label; v = v.; if v != null goto label; interfaceinvoke v.(0); goto label; label: v = v.; v = virtualinvoke v.(v); v = lengthof v; v = v + 1; interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = v.; if v == null goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default groupInstanceId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 3 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; 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.(); 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 = staticinvoke (v); v = virtualinvoke v.(); v = 0 + v; if v < 3 goto label; interfaceinvoke v.(v); virtualinvoke v.(v, 2147483647); goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.protocol.types.Struct, short) { java.lang.Integer v; java.lang.Long v; java.lang.Short v; boolean v, v; java.util.Set v; java.util.List v, v; java.lang.Object[] v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v; java.util.ArrayList v, v; short v, v; int v, v, v, v, v, v; java.lang.String v, v, v, v; java.util.Iterator v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic v; org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v; java.lang.Object v, v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v := @parameter: short; v. = null; if v < 3 goto label; v = virtualinvoke v.("_tagged_fields"); label: v = virtualinvoke v.("transactional_id"); v. = v; v = virtualinvoke v.("group_id"); v. = v; v = virtualinvoke v.("producer_id"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("producer_epoch"); v = virtualinvoke v.(); v. = v; if v < 3 goto label; v = virtualinvoke v.("generation_id"); v = virtualinvoke v.(); v. = v; goto label; label: v = (int) -1; v. = v; label: if v < 3 goto label; v = virtualinvoke v.("member_id"); v. = v; goto label; label: v. = ""; label: if v < 3 goto label; v = virtualinvoke v.("group_instance_id"); v. = v; goto label; label: v. = null; 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.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: if v < 3 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = new java.util.ArrayList; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } public org.apache.kafkaesqueesqueesque.common.protocol.types.Struct toStruct(short) { org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v, v, v; java.lang.Integer v; java.lang.Long v; java.lang.Short v; boolean v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v; java.util.List v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v; short v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Struct[] v; int v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.util.TreeMap v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v, v; java.lang.Object v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: short; v = null; if v < 3 goto label; v = new java.util.TreeMap; specialinvoke v.()>(); v = v; label: v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v); v = v.; virtualinvoke v.("transactional_id", v); v = v.; virtualinvoke v.("group_id", v); v = v.; v = staticinvoke (v); virtualinvoke v.("producer_id", v); v = v.; v = staticinvoke (v); virtualinvoke v.("producer_epoch", v); if v < 3 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("generation_id", v); goto label; label: v = v.; v = (int) -1; if v == v goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default generationId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 3 goto label; v = v.; virtualinvoke v.("member_id", v); goto label; label: v = v.; v = virtualinvoke v.(""); if v != 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default memberId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 3 goto label; v = v.; virtualinvoke v.("group_instance_id", v); goto label; label: v = v.; if v == null goto label; v = new org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default groupInstanceId at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesqueesqueesque.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 < 3 goto label; virtualinvoke v.("_tagged_fields", v); label: return v; } public int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short) { byte[] v, v, v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; short v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.lang.RuntimeException v, v, v, v; org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v; boolean v, v; org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v; java.util.List v, v, v, v, v; java.nio.charset.Charset 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; 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)>("\'transactionalId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 3 goto label; v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = 0 + v; goto label; label: v = lengthof v; v = v + 2; v = 0 + v; 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)>("\'groupId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); if v < 3 goto label; v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = v + v; goto label; label: v = lengthof v; v = v + 2; v = v + v; label: v = v + 8; v = v + 2; if v < 3 goto label; v = v + 4; if v < 3 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)>("\'memberId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = v + v; if v < 3 goto label; v = v.; if v != null goto label; v = v + 1; goto label; 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)>("\'groupInstanceId\' field is too long to be serialized"); throw v; label: v = v.; virtualinvoke v.(v, v); v = lengthof v; v = lengthof v; v = v + 1; v = staticinvoke (v); v = v + v; v = v + v; label: if v < 3 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: 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; 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 < 3 goto label; v = staticinvoke (v); v = v + v; goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesqueesqueesque.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) { byte v; boolean v, v, v, v, v, v; java.util.List v, v, v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v, v; short v, v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; 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: 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: v = v.; v = v.; v = v cmp v; 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.; 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: 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: 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: return 1; } public int hashCode() { java.util.List v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v, v, v; short v; int 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, v, v, v, v, v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = 0 + 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; v = 31 * v; v = v.; v = v >> 32; v = v.; 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 = virtualinvoke 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; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; return v; } public java.lang.String toString() { org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; long v; short v; int v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.util.List v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = v.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = v.; v = v.; v = 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 = v.; if v != null goto label; v = "null"; goto label; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\'\u0001\'"); label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v, v) ("TxnOffsetCommitRequestData(transactionalId=\u, groupId=\u, producerId=\u, producerEpoch=\u, generationId=\u, memberId=\u, groupInstanceId=\u, topics=\u)"); return v; } public java.lang.String transactionalId() { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public java.lang.String groupId() { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public long producerId() { long v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public short producerEpoch() { short v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public int generationId() { int v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public java.lang.String memberId() { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public java.lang.String groupInstanceId() { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public java.util.List topics() { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; java.util.ArrayList v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; 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.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setTransactionalId(java.lang.String) { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setGroupId(java.lang.String) { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setProducerId(long) { long v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: long; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setProducerEpoch(short) { short v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: short; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setGenerationId(int) { int v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setMemberId(java.lang.String) { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setGroupInstanceId(java.lang.String) { java.lang.String v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.lang.String; v. = v; return v; } public org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData setTopics(java.util.List) { java.util.List v; org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData v; v := @this: org.apache.kafkaesqueesqueesque.common.message.TxnOffsetCommitRequestData; v := @parameter: java.util.List; v. = v; return v; } static void () { org.apache.kafkaesqueesqueesque.common.protocol.types.CompactArrayOf v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Field$TaggedFieldsSection v; org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v; java.lang.Object[] v; org.apache.kafkaesqueesqueesque.common.protocol.types.Field[] v, v, v; org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("transactional_id", v, "The ID of the transaction."); v[0] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The ID of the group."); v[1] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("producer_id", v, "The current producer ID in use by the transactional ID."); v[2] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("producer_epoch", v, "The current epoch associated with the producer ID."); v[3] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic that we want to commit offsets for."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v); = v; v = ; = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("transactional_id", v, "The ID of the transaction."); v[0] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("group_id", v, "The ID of the group."); v[1] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("producer_id", v, "The current producer ID in use by the transactional ID."); v[2] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("producer_epoch", v, "The current epoch associated with the producer ID."); v[3] = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic that we want to commit offsets for."); v[4] = v; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[9]; v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field; v = ; specialinvoke v.