public class org.apache.kafkaesque.clients.producer.internals.Sender extends java.lang.Object implements java.lang.Runnable { private final org.slf4j.Logger log; private final org.apache.kafkaesque.clients.KafkaClient client; private final org.apache.kafkaesque.clients.producer.internals.RecordAccumulator accumulator; private final org.apache.kafkaesque.clients.producer.internals.ProducerMetadata metadata; private final boolean guaranteeMessageOrder; private final int maxRequestSize; private final short acks; private final int retries; private final org.apache.kafkaesque.common.utils.Time time; private volatile boolean running; private volatile boolean forceClose; private final org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics sensors; private final int requestTimeoutMs; private final long retryBackoffMs; private final org.apache.kafkaesque.clients.ApiVersions apiVersions; private final org.apache.kafkaesque.clients.producer.internals.TransactionManager transactionManager; private final java.util.Map inFlightBatches; public void (org.apache.kafkaesque.common.utils.LogContext, org.apache.kafkaesque.clients.KafkaClient, org.apache.kafkaesque.clients.producer.internals.ProducerMetadata, org.apache.kafkaesque.clients.producer.internals.RecordAccumulator, boolean, int, short, int, org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry, org.apache.kafkaesque.common.utils.Time, int, long, org.apache.kafkaesque.clients.producer.internals.TransactionManager, org.apache.kafkaesque.clients.ApiVersions) { org.apache.kafkaesque.common.utils.LogContext v; java.util.HashMap v; long v; org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v; short v; org.apache.kafkaesque.clients.KafkaClient v; org.apache.kafkaesque.clients.producer.internals.ProducerMetadata v; int v, v, v; org.apache.kafkaesque.common.utils.Time v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v; boolean v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.ApiVersions v; org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; v := @parameter: org.apache.kafkaesque.clients.KafkaClient; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerMetadata; v := @parameter: org.apache.kafkaesque.clients.producer.internals.RecordAccumulator; v := @parameter: boolean; v := @parameter: int; v := @parameter: short; v := @parameter: int; v := @parameter: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry; v := @parameter: org.apache.kafkaesque.common.utils.Time; v := @parameter: int; v := @parameter: long; v := @parameter: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; specialinvoke v.()>(); v = virtualinvoke v.(class "Lorg/apache/kafkaesque/clients/producer/internals/Sender;"); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = 1; v. = v; v. = v; v. = v; v = new org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics; specialinvoke v.(org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry,org.apache.kafkaesque.clients.Metadata,org.apache.kafkaesque.clients.KafkaClient,org.apache.kafkaesque.common.utils.Time)>(v, v, v, v); v. = v; v. = v; v. = v; v. = v; v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; return; } public java.util.List inFlightBatches(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.common.TopicPartition v; java.util.Map v, v; java.lang.Object v; org.apache.kafkaesque.clients.producer.internals.Sender v; boolean v; java.util.ArrayList v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); goto label; label: v = new java.util.ArrayList; v = v; specialinvoke v.()>(); label: return v; } private void maybeRemoveFromInflightBatches(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { org.apache.kafkaesque.common.TopicPartition v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; java.util.Map v, v; java.lang.Object v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = v.; v = v.; v = interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = v.; interfaceinvoke v.(v); label: return; } private void maybeRemoveAndDeallocateBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; specialinvoke v.(v); v = v.; virtualinvoke v.(v); return; } private java.util.List getExpiredInflightBatches(long) { java.lang.IllegalStateException v; org.apache.kafkaesque.common.TopicPartition v; long v, v, v; java.util.ArrayList v; java.util.Map v; java.lang.String v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch$FinalState v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v; boolean v, v, v, v, v; java.util.Iterator v, v; java.util.Set v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: long; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == 0 goto label; interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; interfaceinvoke v.(v); goto label; label: v = new java.lang.IllegalStateException; v = v.; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u batch created at \u gets unexpected final state \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); goto label; label: return v; } private void addToInflightBatches(java.util.List) { java.util.Iterator v; org.apache.kafkaesque.common.TopicPartition v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.util.ArrayList v; java.util.List v; java.util.Map v, v; java.lang.Object v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: java.util.List; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = v; v = v.; v = v.; interfaceinvoke v.(v, v); label: interfaceinvoke v.(v); goto label; label: return; } public void addToInflightBatches(java.util.Map) { java.util.Iterator v; java.util.Collection v; java.util.Map v; java.lang.Object v; org.apache.kafkaesque.clients.producer.internals.Sender v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: java.util.Map; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v); goto label; label: return; } private boolean hasPendingTransactionalRequests() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public void run() { boolean v, v, v, v, v, v, v, v; java.lang.Exception v, v, v, v; org.apache.kafkaesque.clients.KafkaClient v, v; int v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; interfaceinvoke v.("Starting Kafka producer I/O thread."); label: v = v.; if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Uncaught error in kafka producer I/O thread: ", v); goto label; label: v = v.; interfaceinvoke v.("Beginning shutdown of Kafka producer I/O thread, sending remaining records."); label: v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v > 0 goto label; v = specialinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Uncaught error in kafka producer I/O thread: ", v); goto label; label: v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; interfaceinvoke v.("Aborting incomplete transaction due to shutdown"); v = v.; virtualinvoke v.(); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Uncaught error in kafka producer I/O thread: ", v); goto label; label: v = v.; if v == 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.("Aborting incomplete transactional requests due to forced shutdown"); v = v.; virtualinvoke v.(); label: v = v.; interfaceinvoke v.("Aborting incomplete batches due to forced shutdown"); v = v.; virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Failed to close network client", v); label: v = v.; interfaceinvoke v.("Shutdown of Kafka producer I/O thread has completed."); return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } void runOnce() { long v, v, v, v; org.apache.kafkaesque.clients.KafkaClient v, v; org.apache.kafkaesque.common.utils.Time v, v; boolean v, v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v, v, v, v, v; org.apache.kafkaesque.common.errors.AuthenticationException v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.lang.RuntimeException v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; specialinvoke v.(v); label: v = v.; v = v.; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); label: return; label: v = v.; virtualinvoke v.(); v = specialinvoke v.(); if v == 0 goto label; label: return; label: v := @caughtexception; v = v.; interfaceinvoke v.("Authentication exception while processing transactional request", v); v = v.; virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); v = specialinvoke v.(v); v = v.; interfaceinvoke v.(v, v); return; catch org.apache.kafkaesque.common.errors.AuthenticationException from label to label with label; catch org.apache.kafkaesque.common.errors.AuthenticationException from label to label with label; } private long sendProducerData(long) { org.apache.kafkaesque.common.Cluster v; java.lang.Integer v; java.lang.Long v; java.util.Map v; org.apache.kafkaesque.clients.producer.internals.ProducerMetadata v, v, v; java.util.Set v, v, v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator$ReadyCheckResult v; org.apache.kafkaesque.common.errors.TimeoutException v; long v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v; org.apache.kafkaesque.clients.KafkaClient v, v; java.lang.String v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; boolean v, v, v, v, v, v, v, v, v, v, v; java.util.Collection v; java.util.List v, v; org.apache.kafkaesque.common.TopicPartition v, v; int v, v, v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v, v, v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v, v, v, v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v, v); goto label; label: v = v.; v = v.; interfaceinvoke v.("Requesting metadata update due to unknown leader topics from the batched records: {}", v); v = v.; virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = 9223372036854775807L; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); if v != 0 goto label; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); v = staticinvoke (v, v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v, v, v); virtualinvoke v.(v); v = v.; if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Expired {} batches in accumulator", v); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = v.; v = v - v; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Expiring \u record(s) for \u0001:\u ms has passed since batch creation"); v = new org.apache.kafkaesque.common.errors.TimeoutException; specialinvoke v.(java.lang.String)>(v); specialinvoke v.(v, -1L, -1L, v, 0); v = v.; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v); v = v.; v = staticinvoke (v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = staticinvoke (v, v); v = staticinvoke (v, 0L); v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v.; interfaceinvoke v.("Nodes with data ready to send: {}", v); v = 0L; label: specialinvoke v.(v, v); return v; } private boolean maybeSendAndPollTransactionalRequest() { java.lang.Integer v; org.apache.kafkaesque.clients.ClientRequest v; org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType v; boolean v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.requests.AbstractRequest$Builder v; java.lang.Object[] v, v; long v, v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler v; org.apache.kafkaesque.clients.KafkaClient v, v, v, v; org.apache.kafkaesque.common.Node v; int v, v, v; org.apache.kafkaesque.common.KafkaException v; org.apache.kafkaesque.common.utils.Time v, v, v, v; java.lang.String v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v, v, v, v; org.slf4j.Logger v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v, v, v, v, v, v; java.io.IOException v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.lang.RuntimeException v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v.; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); return 1; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != null goto label; v = new org.apache.kafkaesque.common.KafkaException; specialinvoke v.(java.lang.String)>("Failing batch since transaction was aborted"); v = v; label: v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; return 0; label: v = virtualinvoke v.(); v = null; label: v = virtualinvoke v.(); v = specialinvoke v.(v); if v != null goto label; specialinvoke v.(v); label: return 1; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v, 1, v, v); v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Sending transactional request {} to node {} with correlation ID {}", v); v = v.; interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); label: return 1; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Disconnect from {} while trying to send request {}. Going to back off and retry.", v); specialinvoke v.(v); return 1; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } private void maybeFindCoordinatorAndRetry(org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v; long v; org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler v; org.apache.kafkaesque.clients.producer.internals.ProducerMetadata v; org.apache.kafkaesque.common.utils.Time v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v.; v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(v); return; } private void maybeAbortBatches(java.lang.RuntimeException) { org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.lang.RuntimeException v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: java.lang.RuntimeException; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("Aborting producer batches due to fatal error", v); v = v.; virtualinvoke v.(v); label: return; } public void initiateClose() { org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; virtualinvoke v.(); v. = 0; virtualinvoke v.(); return; } public void forceClose() { org.apache.kafkaesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v. = 1; virtualinvoke v.(); return; } public boolean isRunning() { org.apache.kafkaesque.clients.producer.internals.Sender v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v = v.; return v; } private org.apache.kafkaesque.common.Node awaitNodeReady(org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType) throws java.io.IOException { org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v; long v; org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.clients.KafkaClient v, v; org.apache.kafkaesque.common.Node v, v; int v; org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType v, v; org.apache.kafkaesque.common.utils.Time v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.common.requests.FindCoordinatorRequest$CoordinatorType; if v == null goto label; v = v.; v = virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); label: v = v; if v == null goto label; v = v.; v = v.; v = v.; v = staticinvoke (v, v, v, v); if v == 0 goto label; v = ; if v != v goto label; v = v.; virtualinvoke v.(); label: return v; label: return null; } private void handleProduceResponse(org.apache.kafkaesque.clients.ClientResponse, java.util.Map, long) { org.apache.kafkaesque.common.protocol.Errors v, v, v; java.lang.Integer v; org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse v, v, v; java.util.Map v, v; boolean v, v, v, v, v, v; java.util.Collection v, v, v; java.util.Set v; org.apache.kafkaesque.clients.ClientResponse v; java.lang.Object[] v; long v, v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v; int v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v, v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v; org.apache.kafkaesque.common.requests.RequestHeader v; org.apache.kafkaesque.clients.producer.internals.Sender v; java.lang.Object v, v, v, v, v, v, v; org.apache.kafkaesque.common.requests.AbstractResponse v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.clients.ClientResponse; v := @parameter: java.util.Map; v := @parameter: long; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Cancelled request with header {} due to node {} being disconnected", v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.Errors)>(v); specialinvoke v.(v, v, v, v, 0L); goto label; label: v = virtualinvoke v.(); if v == null goto label; v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Cancelled request {} due to a version mismatch with node {}", v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.Errors)>(v); specialinvoke v.(v, v, v, v, 0L); goto label; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Received produce response from node {} with correlation id {}", v, v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v + v; specialinvoke v.(v, v, v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.Errors)>(v); specialinvoke v.(v, v, v, v, 0L); goto label; label: return; } private void completeBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch, org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse, long, long, long) { org.apache.kafkaesque.common.protocol.Errors v, v, v, v, v, v; java.lang.Integer v, v; byte v; java.lang.Long v, v; org.apache.kafkaesque.common.errors.TopicAuthorizationException v; org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse v; org.apache.kafkaesque.clients.producer.internals.ProducerMetadata v; boolean v, v, v, v, v, v, v; java.util.Set v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; java.lang.Object[] v, v; org.apache.kafkaesque.common.TopicPartition v, v, v, v, v, v; long v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v; int v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; org.apache.kafkaesque.clients.producer.internals.RecordAccumulator v, v; org.slf4j.Logger v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v, v; org.apache.kafkaesque.common.errors.ApiException v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.Sender v; org.apache.kafkaesque.common.errors.ClusterAuthorizationException v; v := @this: org.apache.kafkaesque.clients.producer.internals.Sender; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v := @parameter: org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v := @parameter: long; v := @parameter: long; v := @parameter: long; v = v.; v = ; if v != v goto label; v = v.; if v <= 1 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v >= 2 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = newarray (java.lang.Object)[4]; v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v = v - v; v = staticinvoke (v); v[2] = v; v[3] = v; interfaceinvoke v.("Got error produce response in correlation id {} on topic-partition {}, splitting and retrying ({} attempts left). Error: {}", v); v = v.; if v == null goto label; v = v.