public class org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest extends org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest
{
public static final long EARLIEST_TIMESTAMP;
public static final long LATEST_TIMESTAMP;
public static final int CONSUMER_REPLICA_ID;
public static final int DEBUGGING_REPLICA_ID;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int MAX_NUM_OFFSETS;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V0;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V0;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V0;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V1;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V1;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V1;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V2;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V3;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V4;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V4;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V4;
private static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V5;
private final int replicaId;
private final org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel;
private final java.util.Map partitionTimestamps;
private final java.util.Set duplicatePartitions;
public static org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] schemaVersions()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)[6];
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V0>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V1>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V2>;
v[2] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V3>;
v[3] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V4>;
v[4] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V5>;
v[5] = v;
return v;
}
private void <init>(int, java.util.Map, org.apache.kafkaesqueesqueesque.common.IsolationLevel, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys v;
short v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
org.apache.kafkaesqueesqueesque.common.IsolationLevel v;
java.util.Map v;
int v;
java.util.Set v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v := @parameter: int;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesqueesque.common.IsolationLevel;
v := @parameter: short;
v = <org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys LIST_OFFSETS>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys,short)>(v, v);
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: int replicaId> = v;
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel> = v;
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps> = v;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Set duplicatePartitions> = v;
return;
}
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v;
java.lang.Integer v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray v, v;
byte v;
java.lang.Long v;
java.util.Map v;
java.lang.Byte v;
boolean v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v, v, v;
java.util.Optional v;
java.lang.Object[] v, v;
org.apache.kafkaesqueesqueesque.common.IsolationLevel v;
java.util.HashMap v;
long v;
java.util.HashSet v;
org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys v;
short v;
int v, v, v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.common.TopicPartition v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Object v, v, v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
v = <org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys LIST_OFFSETS>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys,short)>(v, v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: int replicaId> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: boolean hasField(org.apache.kafkaesqueesqueesque.common.protocol.types.Field)>(v);
if v == 0 goto label;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Byte get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Byte: byte byteValue()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.IsolationLevel: org.apache.kafkaesqueesqueesque.common.IsolationLevel forId(byte)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.common.IsolationLevel: org.apache.kafkaesqueesqueesque.common.IsolationLevel READ_UNCOMMITTED>;
label:
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str)>(v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Object[] get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Long get(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = new org.apache.kafkaesqueesqueesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int MAX_NUM_OFFSETS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getOrElse(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int,int)>(v, 1);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.requests.RequestUtils: java.util.Optional getLeaderEpoch(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int)>(v, v);
v = new org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData: void <init>(long,int,java.util.Optional)>(v, v, v);
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
if v == null goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Set duplicatePartitions> = v;
return;
}
public org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse getErrorResponse(int, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.protocol.Errors v, v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse$PartitionData v, v;
java.util.HashMap v;
short v;
java.util.Map v;
int v;
boolean v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse v;
java.util.List v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
java.util.Optional v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v := @parameter: int;
v := @parameter: java.lang.Throwable;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: short version()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse$PartitionData;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors forException(java.lang.Throwable)>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse$PartitionData: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Errors,java.util.List)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse$PartitionData;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors forException(java.lang.Throwable)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse$PartitionData: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Errors,long,long,java.util.Optional)>(v, -1L, -1L, v);
label:
v = v;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
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()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetResponse: void <init>(int,java.util.Map)>(v, v);
return v;
}
public int replicaId()
{
int v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: int replicaId>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel()
{
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
org.apache.kafkaesqueesqueesque.common.IsolationLevel v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel>;
return v;
}
public java.util.Map partitionTimestamps()
{
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps>;
return v;
}
public java.util.Set duplicatePartitions()
{
java.util.Set v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Set duplicatePartitions>;
return v;
}
public static org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest parse(java.nio.ByteBuffer, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys v;
short v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: short;
v = new org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = <org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys LIST_OFFSETS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct parseRequest(short,java.nio.ByteBuffer)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v);
return v;
}
protected org.apache.kafkaesqueesqueesque.common.protocol.types.Struct toStruct()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v;
java.lang.Integer v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray v, v, v, v;
byte v;
java.util.Map v, v;
java.lang.Byte v;
boolean v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v;
java.util.Set v, v;
java.util.Optional v;
java.lang.Object[] v, v;
org.apache.kafkaesqueesqueesque.common.IsolationLevel v;
long v;
java.util.ArrayList v, v;
org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys v;
short v;
int v, v, v;
java.util.Iterator v, v;
org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v, v, v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: short version()>();
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys LIST_OFFSETS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema requestSchema(short)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: java.util.Map partitionTimestamps>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.CollectionUtils: java.util.Map groupPartitionDataByTopic(java.util.Map)>(v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: int replicaId>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.IsolationLevel isolationLevel>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.IsolationLevel: byte id()>();
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: 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 = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct instance(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str,java.lang.String)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map: 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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct instance(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray)>(v);
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData: long timestamp>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int,long)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int MAX_NUM_OFFSETS>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData: int maxNumOffsets>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct setIfExists(org.apache.kafkaesqueesqueesque.common.protocol.types.Field,java.lang.Object)>(v, v);
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData: java.util.Optional currentLeaderEpoch>;
staticinvoke <org.apache.kafkaesqueesqueesque.common.requests.RequestUtils: void setLeaderEpochIfExists(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int,java.util.Optional)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray,java.lang.Object[])>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray,java.lang.Object[])>(v, v);
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema 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;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field[] v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("replica_id", "Broker id of the follower. For normal consumers, use -1.");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int8: void <init>(java.lang.String,java.lang.String)>("isolation_level", "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");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: void <init>(java.lang.String,java.lang.String)>("topics", "Topics to list offsets.");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: void <init>(java.lang.String,java.lang.String)>("partitions", "Partitions to list offsets.");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int64: void <init>(java.lang.String,java.lang.String)>("timestamp", "The target timestamp for the partition.");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int32: void <init>(java.lang.String,java.lang.String)>("max_num_offsets", "Maximum offsets to return.");
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int MAX_NUM_OFFSETS> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int MAX_NUM_OFFSETS>;
v[2] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V0> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V0>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V0> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V0>;
v[1] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V0> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V1> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V1>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V1> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V1>;
v[1] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V1> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V1>;
v[2] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V2> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V2>;
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V3> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray PARTITIONS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int CURRENT_LEADER_EPOCH>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int TIMESTAMP>;
v[2] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V4> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray TOPICS>;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field PARTITIONS_V4>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field$ComplexArray: org.apache.kafkaesqueesqueesque.common.protocol.types.Field withFields(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V4> = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int REPLICA_ID>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field$Int ISOLATION_LEVEL>;
v[1] = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Field TOPICS_V4>;
v[2] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V4> = v;
v = <org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V4>;
<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema LIST_OFFSET_REQUEST_V5> = v;
return;
}
}