class org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler extends org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler
{
private final org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder;
final org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0;
private void <init>(org.apache.kafkaesque.clients.producer.internals.TransactionManager, org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult, org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder)
{
org.apache.kafkaesque.clients.producer.internals.TransactionManager v;
org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder v;
org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v := @parameter: org.apache.kafkaesque.clients.producer.internals.TransactionManager;
v := @parameter: org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult;
v := @parameter: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder;
v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0> = v;
specialinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler: void <init>(org.apache.kafkaesque.clients.producer.internals.TransactionManager,org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult)>(v, v);
v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder> = v;
return;
}
org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder requestBuilder()
{
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder>;
return v;
}
org.apache.kafkaesque.clients.producer.internals.TransactionManager$Priority priority()
{
org.apache.kafkaesque.clients.producer.internals.TransactionManager$Priority v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v = <org.apache.kafkaesque.clients.producer.internals.TransactionManager$Priority: org.apache.kafkaesque.clients.producer.internals.TransactionManager$Priority ADD_PARTITIONS_OR_OFFSETS>;
return v;
}
org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType coordinatorType()
{
org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v = <org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType GROUP>;
return v;
}
java.lang.String coordinatorKey()
{
org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder v;
java.lang.String v;
org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder>;
v = v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder: org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData data>;
v = virtualinvoke v.<org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData: java.lang.String groupId()>();
return v;
}
public void handleResponse(org.apache.kafkaesque.common.requests.AbstractResponse)
{
org.apache.kafkaesque.common.protocol.Errors v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder v, v, v;
org.apache.kafkaesque.common.errors.GroupAuthorizationException v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
java.util.Map v, v, v, v;
org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData v, v, v;
boolean v, v, v, v, v;
java.util.Set v;
org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v, v;
org.apache.kafkaesque.common.KafkaException v;
java.lang.String v, v, v, v, v, v, v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.CommitFailedException v;
org.apache.kafkaesque.common.errors.ApiException v, v, v;
java.lang.Object v, v, v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler;
v := @parameter: org.apache.kafkaesque.common.requests.AbstractResponse;
v = 0;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitResponse: java.util.Map errors()>();
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder>;
v = v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder: org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData data>;
v = virtualinvoke v.<org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData: java.lang.String groupId()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Received TxnOffsetCommit response for consumer group {}: {}", v, v);
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 getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors NONE>;
if v != v goto label;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: java.util.Map pendingTxnOffsetCommits>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors NOT_COORDINATOR>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors REQUEST_TIMED_OUT>;
if v != v goto label;
label:
if v != 0 goto label;
v = 1;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = <org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType GROUP>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder>;
v = v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder: org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData data>;
v = virtualinvoke v.<org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData: java.lang.String groupId()>();
specialinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: void lookupCoordinator(org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType,java.lang.String)>(v, v);
goto label;
label:
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors UNKNOWN_TOPIC_OR_PARTITION>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors GROUP_AUTHORIZATION_FAILED>;
if v != v goto label;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder builder>;
v = v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitRequest$Builder: org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData data>;
v = virtualinvoke v.<org.apache.kafkaesque.common.message.TxnOffsetCommitRequestData: java.lang.String groupId()>();
v = staticinvoke <org.apache.kafkaesque.common.errors.GroupAuthorizationException: org.apache.kafkaesque.common.errors.GroupAuthorizationException forGroupId(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors FENCED_INSTANCE_ID>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors UNKNOWN_MEMBER_ID>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors ILLEGAL_GENERATION>;
if v != v goto label;
label:
v = new org.apache.kafkaesque.clients.consumer.CommitFailedException;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.errors.ApiException exception()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.errors.ApiException: java.lang.String getMessage()>();
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[])>("Transaction offset Commit failed due to consumer group metadata mismatch: \u0001");
specialinvoke v.<org.apache.kafkaesque.clients.consumer.CommitFailedException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = specialinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: boolean isFatalException(org.apache.kafkaesque.common.protocol.Errors)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void fatalError(java.lang.RuntimeException)>(v);
goto label;
label:
v = new org.apache.kafkaesque.common.KafkaException;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.Errors: java.lang.String message()>();
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[])>("Unexpected error in TxnOffsetCommitResponse: \u0001");
specialinvoke v.<org.apache.kafkaesque.common.KafkaException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void fatalError(java.lang.RuntimeException)>(v);
label:
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult result>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult: boolean isCompleted()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: java.util.Map pendingTxnOffsetCommits>;
interfaceinvoke v.<java.util.Map: void clear()>();
goto label;
label:
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager: java.util.Map pendingTxnOffsetCommits>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult result>;
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult: void done()>();
goto label;
label:
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler: void reenqueue()>();
label:
return;
}
}