class org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler extends org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler
{
private final org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder builder;
private final java.util.Map offsets;
private final org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata;
final org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0;
private void <init>(org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager, org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder, java.util.Map, org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata)
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager v;
org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler;
v := @parameter: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0> = v;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler: void <init>(org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager,java.lang.String)>(v, "AddOffsetsToTxn");
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder builder> = v;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: java.util.Map offsets> = v;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata> = v;
return;
}
org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder requestBuilder()
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler v;
org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder builder>;
return v;
}
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority priority()
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler;
v = <org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority ADD_PARTITIONS_OR_OFFSETS>;
return v;
}
public void handleResponse(org.apache.kafkaesqueesque.common.requests.AbstractResponse)
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult v;
java.util.PriorityQueue v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler v;
java.util.Map v;
org.apache.kafkaesqueesque.common.protocol.Errors v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
org.apache.kafkaesqueesque.common.errors.GroupAuthorizationException v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler v;
org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder v, v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v;
org.apache.kafkaesqueesque.common.errors.ApiException v, v, v;
org.apache.kafkaesqueesque.common.KafkaException v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractResponse;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnResponse: org.apache.kafkaesqueesque.common.protocol.Errors error()>();
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NONE>;
if v != v goto label;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder builder>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder: java.lang.String consumerGroupId()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Successfully added partition for consumer group {} to transaction", v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: java.util.PriorityQueue pendingRequests>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult result>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: java.util.Map offsets>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata>;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler txnOffsetCommitHandler(org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult,java.util.Map,org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata)>(v, v, v);
virtualinvoke v.<java.util.PriorityQueue: boolean add(java.lang.Object)>(v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: boolean transactionStarted> = 1;
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NOT_COORDINATOR>;
if v != v goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = <org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType TRANSACTION>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: java.lang.String transactionalId>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: void lookupCoordinator(org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void reenqueue()>();
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors CONCURRENT_TRANSACTIONS>;
if v != v goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void reenqueue()>();
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors UNKNOWN_PRODUCER_ID>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors INVALID_PRODUCER_ID_MAPPING>;
if v != v goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void abortableErrorIfPossible(java.lang.RuntimeException)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors INVALID_PRODUCER_EPOCH>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors TRANSACTIONAL_ID_AUTHORIZATION_FAILED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors GROUP_AUTHORIZATION_FAILED>;
if v != v goto label;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder builder>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.AddOffsetsToTxnRequest$Builder: java.lang.String consumerGroupId()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.errors.GroupAuthorizationException: org.apache.kafkaesqueesque.common.errors.GroupAuthorizationException forGroupId(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.KafkaException;
v = virtualinvoke v.<org.apache.kafkaesqueesque.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 AddOffsetsToTxnResponse: \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
label:
return;
}
}