public class org.apache.kafkaesque.clients.consumer.internals.SubscriptionState extends java.lang.Object
{
private static final java.lang.String SUBSCRIPTION_EXCEPTION_MESSAGE;
private final org.slf4j.Logger log;
private org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType;
private java.util.regex.Pattern subscribedPattern;
private java.util.Set subscription;
private java.util.Set groupSubscription;
private final org.apache.kafkaesque.common.internals.PartitionStates assignment;
private final org.apache.kafkaesque.clients.consumer.OffsetResetStrategy defaultResetStrategy;
private org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener rebalanceListener;
private int assignmentId;
public synchronized java.lang.String toString()
{
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
java.util.List v;
org.apache.kafkaesque.common.internals.PartitionStates v;
int v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.String v, v, v;
java.util.regex.Pattern v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = staticinvoke <java.lang.String: java.lang.String join(java.lang.CharSequence,java.lang.Iterable)>(",", v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription>;
v = staticinvoke <java.lang.String: java.lang.String join(java.lang.CharSequence,java.lang.Iterable)>(",", v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy defaultResetStrategy>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.List partitionStateValues()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType,java.util.regex.Pattern,java.lang.String,java.lang.String,org.apache.kafkaesque.clients.consumer.OffsetResetStrategy,java.util.List,int)>(v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SubscriptionState{type=\u, subscribedPattern=\u, subscription=\u, groupSubscription=\u, defaultResetStrategy=\u, assignment=\u (id=\u)}");
return v;
}
public synchronized java.lang.String prettyString()
{
java.lang.IllegalStateException v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v;
int[] v;
int v, v, v;
java.lang.String v, v, v, v, v;
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.regex.Pattern v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$1: int[] $SwitchMap$org$apache$kafka$clients$consumer$internals$SubscriptionState$SubscriptionType>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
return "None";
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = staticinvoke <java.lang.String: java.lang.String join(java.lang.CharSequence,java.lang.Iterable)>(",", v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Subscribe(\u)");
return v;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.regex.Pattern)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Subscribe(\u)");
return v;
label:
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set assignedPartitions()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Set,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Assign(\u , id=\u)");
return v;
label:
v = new java.lang.IllegalStateException;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unrecognized subscription type: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
}
public void <init>(org.apache.kafkaesque.common.utils.LogContext, org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)
{
org.apache.kafkaesque.common.utils.LogContext v;
org.slf4j.Logger v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
java.util.HashSet v, v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Class v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.utils.LogContext;
v := @parameter: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId> = 0;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.utils.LogContext: org.slf4j.Logger logger(java.lang.Class)>(v);
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log> = v;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy defaultResetStrategy> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription> = v;
v = new org.apache.kafkaesque.common.internals.PartitionStates;
specialinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription> = v;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern> = null;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType NONE>;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType> = v;
return;
}
synchronized int assignmentId()
{
int v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
return v;
}
private void setSubscriptionType(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)
{
java.lang.IllegalStateException v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType NONE>;
if v != v goto label;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType> = v;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
if v == v goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Subscription to topics, partitions and pattern are mutually exclusive");
throw v;
label:
return;
}
public synchronized boolean subscribe(java.util.Set, org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener)
{
org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener v;
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void registerRebalanceListener(org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener)>(v);
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_TOPICS>;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void setSubscriptionType(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean changeSubscription(java.util.Set)>(v);
return v;
}
public synchronized void subscribe(java.util.regex.Pattern, org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener)
{
org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.regex.Pattern v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.regex.Pattern;
v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void registerRebalanceListener(org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener)>(v);
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_PATTERN>;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void setSubscriptionType(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)>(v);
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern> = v;
return;
}
public synchronized boolean subscribeFromPattern(java.util.Set)
{
java.util.Set v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_PATTERN>;
if v == v goto label;
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Attempt to subscribe from pattern while subscription type set to \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean changeSubscription(java.util.Set)>(v);
return v;
}
private boolean changeSubscription(java.util.Set)
{
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = interfaceinvoke v.<java.util.Set: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return 0;
label:
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription> = v;
return 1;
}
synchronized boolean groupSubscribe(java.util.Collection)
{
java.lang.IllegalStateException v;
java.util.Collection v;
java.util.Set v, v;
java.util.HashSet v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Collection;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean hasAutoAssignedPartitions()>();
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Subscription to topics, partitions and pattern are mutually exclusive");
throw v;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription>;
v = interfaceinvoke v.<java.util.Set: boolean containsAll(java.util.Collection)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
synchronized void resetGroupSubscription()
{
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription> = v;
return;
}
public synchronized boolean assignFromUser(java.util.Set)
{
java.util.HashMap v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
java.util.HashSet v;
org.apache.kafkaesque.common.internals.PartitionStates v, v, v;
int v, v;
java.lang.String v;
boolean v, v, v;
java.util.Iterator v;
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType USER_ASSIGNED>;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void setSubscriptionType(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.Set partitionSet()>();
v = interfaceinvoke v.<java.util.Set: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
v = v + 1;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.lang.Object stateValue(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = new org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void <init>()>();
v = v;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: void set(java.util.Map)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean changeSubscription(java.util.Set)>(v);
return v;
}
public synchronized boolean checkAssignmentMatchedSubscription(java.util.Collection)
{
java.util.regex.Matcher v;
java.lang.String v, v;
boolean v, v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
java.util.regex.Pattern v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Collection;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Assigned partition {} for non-subscribed topic regex pattern; subscription pattern is {}", v, v);
return 0;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Assigned partition {} for non-subscribed topic; subscription is {}", v, v);
return 0;
label:
return 1;
}
public synchronized void assignFromSubscribed(java.util.Collection)
{
java.util.Iterator v;
java.util.Collection v;
java.util.HashMap v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.internals.PartitionStates v, v;
int v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v, v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Collection;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean hasAutoAssignedPartitions()>();
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Attempt to dynamically assign partitions while manual assignment in use");
throw v;
label:
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.Collection: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.lang.Object stateValue(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = new org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void <init>()>();
v = v;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
v = v + 1;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: void set(java.util.Map)>(v);
return;
}
private void registerRebalanceListener(org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener)
{
org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.IllegalArgumentException v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("RebalanceListener cannot be null");
throw v;
label:
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener rebalanceListener> = v;
return;
}
synchronized boolean hasPatternSubscription()
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_PATTERN>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized boolean hasNoSubscriptionOrUserAssignment()
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType NONE>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized void unsubscribe()
{
org.apache.kafkaesque.common.internals.PartitionStates v;
int v, v;
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription> = v;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: void clear()>();
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern> = null;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType NONE>;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId>;
v = v + 1;
v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId> = v;
return;
}
synchronized boolean matchesSubscribedPattern(java.lang.String)
{
java.util.regex.Matcher v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.String v;
java.util.regex.Pattern v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.regex.Pattern subscribedPattern>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean hasPatternSubscription()>();
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
return v;
label:
return 0;
}
public synchronized java.util.Set subscription()
{
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean hasAutoAssignedPartitions()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
return v;
label:
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
return v;
}
public synchronized java.util.Set pausedPartitions()
{
java.util.function.Predicate v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_pausedPartitions_0__561: java.util.function.Predicate bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Collection collectPartitions(java.util.function.Predicate,java.util.stream.Collector)>(v, v);
return v;
}
synchronized java.util.Set metadataTopics()
{
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription>;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription>;
label:
return v;
}
synchronized boolean needsMetadata(java.lang.String)
{
java.util.Set v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set groupSubscription>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)
{
java.lang.IllegalStateException v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.lang.Object stateValue(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.common.TopicPartition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No current assignment for partition \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.lang.Object stateValue(org.apache.kafkaesque.common.TopicPartition)>(v);
return v;
}
public synchronized void seekValidated(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void seekValidated(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
return;
}
public void seek(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = new org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: void <init>(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void seekValidated(org.apache.kafkaesque.common.TopicPartition,org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v, v);
return;
}
public void seekUnvalidated(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void seekUnvalidated(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
return;
}
synchronized void maybeSeekUnvalidated(org.apache.kafkaesque.common.TopicPartition, long, org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)
{
org.slf4j.Logger v, v, v, v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v, v;
org.apache.kafkaesque.common.TopicPartition v;
long v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v := @parameter: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Skipping reset of partition {} since it is no longer assigned", v);
goto label;
label:
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean awaitingReset()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Skipping reset of partition {} since reset is no longer needed", v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy resetStrategy>;
if v == v goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Skipping reset of partition {} since an alternative reset has been requested", v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Resetting offset for partition {} to offset {}.", v, v);
v = new org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: void <init>(long)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void seekUnvalidated(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
label:
return;
}
public synchronized java.util.Set assignedPartitions()
{
java.util.HashSet v;
org.apache.kafkaesque.common.internals.PartitionStates v;
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = new java.util.HashSet;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.Set partitionSet()>();
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
return v;
}
public synchronized java.util.List assignedPartitionsList()
{
org.apache.kafkaesque.common.internals.PartitionStates v;
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = new java.util.ArrayList;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.Set partitionSet()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
synchronized int numAssignedPartitions()
{
int v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.common.internals.PartitionStates v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: int size()>();
return v;
}
synchronized java.util.List fetchablePartitions(java.util.function.Predicate)
{
java.util.function.Predicate v, v;
java.util.function.Function v;
java.util.stream.Stream v, v, v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.function.Predicate;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_fetchablePartitions_1__562: java.util.function.Predicate bootstrap$(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$topicPartition__563: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
public synchronized boolean hasAutoAssignedPartitions()
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType v, v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_TOPICS>;
if v == v goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType subscriptionType>;
v = <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$SubscriptionType AUTO_PATTERN>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized void position(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void position(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
return;
}
public synchronized boolean maybeValidatePositionForCurrentLeader(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean maybeValidatePosition(org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch)>(v);
return v;
}
public synchronized java.util.Optional maybeCompleteValidation(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition, org.apache.kafkaesque.common.requests.EpochEndOffset)
{
java.lang.Integer v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v, v, v;
org.apache.kafkaesque.common.requests.EpochEndOffset v;
byte v;
boolean v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.clients.consumer.OffsetAndMetadata v;
java.util.Optional v, v, v, v;
java.lang.Object[] v, v, v;
org.apache.kafkaesque.common.TopicPartition v;
long v, v, v, v;
int v, v;
org.slf4j.Logger v, v, v, v, v;
org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v := @parameter: org.apache.kafkaesque.common.requests.EpochEndOffset;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Skipping completed validation for partition {} which is not currently assigned.", v);
goto label;
label:
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean awaitingValidation()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Skipping completed validation for partition {} which is no longer expecting validation.", v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Skipping completed validation for partition {} since the current position {} no longer matches the position {} when the request was sent", v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.EpochEndOffset: long endOffset()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v cmp v;
if v >= 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: boolean hasDefaultOffsetResetPolicy()>();
if v == 0 goto label;
v = new org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.EpochEndOffset: long endOffset()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.EpochEndOffset: int leaderEpoch()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch currentLeader>;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: void <init>(long,java.util.Optional,org.apache.kafkaesque.clients.Metadata$LeaderAndEpoch)>(v, v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Truncation detected for partition {} at offset {}, resetting offset to the first offset known to diverge {}", v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void seekValidated(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object[])>("Truncation detected for partition {} at offset {} (the end offset from the broker is {}), but no reset policy is set", v);
v = new org.apache.kafkaesque.clients.consumer.OffsetAndMetadata;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.EpochEndOffset: long endOffset()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.EpochEndOffset: int leaderEpoch()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.OffsetAndMetadata: void <init>(long,java.util.Optional,java.lang.String)>(v, v, null);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
return v;
label:
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void completeValidation()>();
label:
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
return v;
}
public synchronized boolean awaitingValidation(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean awaitingValidation()>();
return v;
}
public synchronized void completeValidation(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void completeValidation()>();
return;
}
public synchronized org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition validPosition(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition validPosition()>();
return v;
}
public synchronized org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
return v;
}
synchronized java.lang.Long partitionLag(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.common.IsolationLevel)
{
org.apache.kafkaesque.common.TopicPartition v;
long v, v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v, v;
java.lang.Long v, v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.IsolationLevel v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.common.IsolationLevel;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = <org.apache.kafkaesque.common.IsolationLevel: org.apache.kafkaesque.common.IsolationLevel READ_COMMITTED>;
if v != v goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long lastStableOffset>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long lastStableOffset>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
return v;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long highWatermark>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long highWatermark>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
return v;
}
synchronized java.lang.Long partitionLead(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.common.TopicPartition v;
long v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v, v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long logStartOffset>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long logStartOffset>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
return v;
}
synchronized void updateHighWatermark(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void highWatermark(java.lang.Long)>(v);
return;
}
synchronized void updateLogStartOffset(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void logStartOffset(java.lang.Long)>(v);
return;
}
synchronized void updateLastStableOffset(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void lastStableOffset(java.lang.Long)>(v);
return;
}
public synchronized void updatePreferredReadReplica(org.apache.kafkaesque.common.TopicPartition, int, java.util.function.Supplier)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
int v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.function.Supplier v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: int;
v := @parameter: java.util.function.Supplier;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void updatePreferredReadReplica(int,java.util.function.Supplier)>(v, v);
return;
}
public synchronized java.util.Optional preferredReadReplica(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.Optional v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v != null goto label;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
return v;
label:
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.util.Optional preferredReadReplica(long)>(v);
return v;
}
public synchronized java.util.Optional clearPreferredReadReplica(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.Optional v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.util.Optional clearPreferredReadReplica()>();
return v;
}
public synchronized java.util.Map allConsumed()
{
java.util.function.Consumer v;
java.util.stream.Stream v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.HashMap v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_allConsumed_2__564: java.util.function.Consumer bootstrap$(java.util.Map)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return v;
}
public synchronized void requestOffsetReset(org.apache.kafkaesque.common.TopicPartition, org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void reset(org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)>(v);
return;
}
public synchronized void requestOffsetReset(java.util.Collection, org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)
{
java.util.function.Consumer v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_requestOffsetReset_3__565: java.util.function.Consumer bootstrap$(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState,org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)>(v, v);
interfaceinvoke v.<java.util.Collection: void forEach(java.util.function.Consumer)>(v);
return;
}
public void requestOffsetReset(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy defaultResetStrategy>;
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: void requestOffsetReset(org.apache.kafkaesque.common.TopicPartition,org.apache.kafkaesque.clients.consumer.OffsetResetStrategy)>(v, v);
return;
}
synchronized void setNextAllowedRetry(java.util.Set, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
long v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v := @parameter: long;
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 = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void setNextAllowedRetry(long)>(v);
goto label;
label:
return;
}
boolean hasDefaultOffsetResetPolicy()
{
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy defaultResetStrategy>;
v = <org.apache.kafkaesque.clients.consumer.OffsetResetStrategy: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy NONE>;
if v == v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized boolean isOffsetResetNeeded(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean awaitingReset()>();
return v;
}
public synchronized org.apache.kafkaesque.clients.consumer.OffsetResetStrategy resetStrategy(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.clients.consumer.OffsetResetStrategy v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesque.clients.consumer.OffsetResetStrategy resetStrategy()>();
return v;
}
public synchronized boolean hasAllFetchPositions()
{
java.util.stream.Stream v;
org.apache.kafkaesque.common.internals.PartitionStates v;
java.util.function.Predicate v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_hasAllFetchPositions_4__566: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: boolean allMatch(java.util.function.Predicate)>(v);
return v;
}
public synchronized java.util.Set missingFetchPositions()
{
java.util.function.Predicate v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_missingFetchPositions_5__567: java.util.function.Predicate bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Collection collectPartitions(java.util.function.Predicate,java.util.stream.Collector)>(v, v);
return v;
}
private java.util.Collection collectPartitions(java.util.function.Predicate, java.util.stream.Collector)
{
java.util.function.Predicate v, v;
java.util.function.Function v;
java.util.stream.Stream v, v, v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.function.Predicate;
v := @parameter: java.util.stream.Collector;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_collectPartitions_6__568: java.util.function.Predicate bootstrap$(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$topicPartition__569: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
public synchronized void resetMissingPositions()
{
java.util.HashSet v;
java.util.function.Consumer v;
java.util.stream.Stream v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.NoOffsetForPartitionException v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_resetMissingPositions_7__570: java.util.function.Consumer bootstrap$(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState,java.util.Set)>(v, v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesque.clients.consumer.NoOffsetForPartitionException;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.NoOffsetForPartitionException: void <init>(java.util.Collection)>(v);
throw v;
label:
return;
}
public synchronized java.util.Set partitionsNeedingReset(long)
{
java.util.function.Predicate v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: long;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_partitionsNeedingReset_8__571: java.util.function.Predicate bootstrap$(long)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Collection collectPartitions(java.util.function.Predicate,java.util.stream.Collector)>(v, v);
return v;
}
public synchronized java.util.Set partitionsNeedingValidation(long)
{
java.util.function.Predicate v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
long v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: long;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$lambda_partitionsNeedingValidation_9__572: java.util.function.Predicate bootstrap$(long)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Collection collectPartitions(java.util.function.Predicate,java.util.stream.Collector)>(v, v);
return v;
}
public synchronized boolean isAssigned(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
v = virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: boolean contains(org.apache.kafkaesque.common.TopicPartition)>(v);
return v;
}
public synchronized boolean isPaused(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v == null goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean isPaused()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
synchronized boolean isFetchable(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v == null goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean isFetchable()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized boolean hasValidPosition(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v == null goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean hasValidPosition()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized void pause(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void pause()>();
return;
}
public synchronized void resume(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedState(org.apache.kafkaesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void resume()>();
return;
}
synchronized void requestFailed(java.util.Set, long)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v;
long v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: java.util.Set;
v := @parameter: long;
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 = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState assignedStateOrNull(org.apache.kafkaesque.common.TopicPartition)>(v);
if v == null goto label;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void requestFailed(long)>(v);
goto label;
label:
return;
}
synchronized void movePartitionToEnd(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
org.apache.kafkaesque.common.internals.PartitionStates v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.common.internals.PartitionStates assignment>;
virtualinvoke v.<org.apache.kafkaesque.common.internals.PartitionStates: void moveToEnd(org.apache.kafkaesque.common.TopicPartition)>(v);
return;
}
public synchronized org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener rebalanceListener()
{
org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesque.clients.consumer.ConsumerRebalanceListener rebalanceListener>;
return v;
}
}