public class org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer extends java.lang.Object implements org.apache.kafkaesqueesqueesque.clients.producer.Producer { private final org.slf4j.Logger log; private static final java.lang.String JMX_PREFIX; public static final java.lang.String NETWORK_THREAD_PREFIX; public static final java.lang.String PRODUCER_METRIC_GROUP_NAME; private final java.lang.String clientId; final org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics; private final org.apache.kafkaesqueesqueesque.clients.producer.Partitioner partitioner; private final int maxRequestSize; private final long totalMemorySize; private final org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata metadata; private final org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator accumulator; private final org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender sender; private final java.lang.Thread ioThread; private final org.apache.kafkaesqueesqueesque.common.record.CompressionType compressionType; private final org.apache.kafkaesqueesqueesque.common.metrics.Sensor errors; private final org.apache.kafkaesqueesqueesque.common.utils.Time time; private final org.apache.kafkaesqueesqueesque.common.serialization.Serializer keySerializer; private final org.apache.kafkaesqueesqueesque.common.serialization.Serializer valueSerializer; private final org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig producerConfig; private final long maxBlockTimeMs; private final org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors interceptors; private final org.apache.kafkaesqueesqueesque.clients.ApiVersions apiVersions; private final org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager transactionManager; public void (java.util.Map) { org.apache.kafkaesqueesqueesque.common.utils.Time v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; java.util.Map v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Map; v = ; specialinvoke v.(java.util.Map,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata,org.apache.kafkaesqueesqueesque.clients.KafkaClient,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, null, null, null, null, null, v); return; } public void (java.util.Map, org.apache.kafkaesqueesqueesque.common.serialization.Serializer, org.apache.kafkaesqueesqueesque.common.serialization.Serializer) { java.util.Map v; org.apache.kafkaesqueesqueesque.common.utils.Time v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.common.serialization.Serializer v, v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v = ; specialinvoke v.(java.util.Map,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata,org.apache.kafkaesqueesqueesque.clients.KafkaClient,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, v, v, null, null, null, v); return; } public void (java.util.Properties) { java.util.Properties v; java.util.Map v; org.apache.kafkaesqueesqueesque.common.utils.Time v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Properties; v = staticinvoke (v); v = ; specialinvoke v.(java.util.Map,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata,org.apache.kafkaesqueesqueesque.clients.KafkaClient,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, null, null, null, null, null, v); return; } public void (java.util.Properties, org.apache.kafkaesqueesqueesque.common.serialization.Serializer, org.apache.kafkaesqueesqueesque.common.serialization.Serializer) { java.util.Properties v; java.util.Map v; org.apache.kafkaesqueesqueesque.common.utils.Time v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.common.serialization.Serializer v, v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Properties; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v = staticinvoke (v); v = ; specialinvoke v.(java.util.Map,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.common.serialization.Serializer,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata,org.apache.kafkaesqueesqueesque.clients.KafkaClient,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, v, v, null, null, null, v); return; } void (java.util.Map, org.apache.kafkaesqueesqueesque.common.serialization.Serializer, org.apache.kafkaesqueesqueesque.common.serialization.Serializer, org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata, org.apache.kafkaesqueesqueesque.clients.KafkaClient, org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors, org.apache.kafkaesqueesqueesque.common.utils.Time) { org.apache.kafkaesqueesqueesque.common.internals.ClusterResourceListeners v; java.lang.Integer v, v, v, v; java.lang.Long v, v, v, v, v, v; java.lang.Thread v; java.time.Duration v; java.util.Map v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata v, v, v, v; org.apache.kafkaesqueesqueesque.common.KafkaException v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v, v; org.apache.kafkaesqueesqueesque.common.utils.Time v, v; java.lang.Throwable v; java.lang.Object[] v, v; long v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.KafkaClient v; org.apache.kafkaesqueesqueesque.common.metrics.JmxReporter v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.ApiVersions v, v; org.apache.kafkaesqueesqueesque.common.utils.LogContext v, v, v; org.apache.kafkaesqueesqueesque.common.metrics.Sensor v; org.apache.kafkaesqueesqueesque.common.metrics.Sensor$RecordingLevel v; java.util.List[] v; org.apache.kafkaesqueesqueesque.common.metrics.MetricConfig v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.utils.KafkaThread v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; boolean v; org.apache.kafkaesqueesqueesque.clients.producer.internals.BufferPool v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v, v; org.apache.kafkaesqueesqueesque.common.record.CompressionType v, v; java.util.List v, v, v, v; org.apache.kafkaesqueesqueesque.common.metrics.Metrics v, v, v, v, v; int v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator v; org.slf4j.Logger v, v, v, v; java.util.concurrent.TimeUnit v; java.lang.Object v, v, v, v; org.apache.kafkaesqueesqueesque.common.serialization.Serializer v, v, v, v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v := @parameter: org.apache.kafkaesqueesqueesque.common.serialization.Serializer; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata; v := @parameter: org.apache.kafkaesqueesqueesque.clients.KafkaClient; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors; v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Time; specialinvoke v.()>(); v = new org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v = staticinvoke (v, v, v); specialinvoke v.(java.util.Map)>(v); label: v = virtualinvoke v.(); v. = v; v. = v; v = interfaceinvoke v.("transactional.id"); if v == 0 goto label; v = interfaceinvoke v.("transactional.id"); goto label; label: v = null; label: v = virtualinvoke v.("client.id"); v. = v; if v != null goto label; v = new org.apache.kafkaesqueesqueesque.common.utils.LogContext; v = newarray (java.lang.Object)[1]; v = v.; v[0] = v; v = staticinvoke ("[Producer clientId=%s] ", v); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = new org.apache.kafkaesqueesqueesque.common.utils.LogContext; v = newarray (java.lang.Object)[2]; v = v.; v[0] = v; v[1] = v; v = staticinvoke ("[Producer clientId=%s, transactionalId=%s] ", v); specialinvoke v.(java.lang.String)>(v); v = v; label: v = virtualinvoke v.(class "Lorg/apache/kafkaesqueesqueesque/clients/producer/KafkaProducer;"); v. = v; v = v.; interfaceinvoke v.("Starting the Kafka producer"); v = v.; v = staticinvoke ("client-id", v); v = new org.apache.kafkaesqueesqueesque.common.metrics.MetricConfig; specialinvoke v.()>(); v = virtualinvoke v.("metrics.num.samples"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("metrics.sample.window.ms"); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v, v); v = virtualinvoke v.("metrics.recording.level"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = v.; v = staticinvoke ("client.id", v); v = virtualinvoke v.("metric.reporters", class "Lorg/apache/kafkaesqueesqueesque/common/metrics/MetricsReporter;", v); v = new org.apache.kafkaesqueesqueesque.common.metrics.JmxReporter; specialinvoke v.(java.lang.String)>("kafka.producer"); interfaceinvoke v.(v); v = new org.apache.kafkaesqueesqueesque.common.metrics.Metrics; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.metrics.MetricConfig,java.util.List,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, v, v); v. = v; v = virtualinvoke v.("partitioner.class", class "Lorg/apache/kafkaesqueesqueesque/clients/producer/Partitioner;"); v. = v; v = virtualinvoke v.("retry.backoff.ms"); v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.("key.serializer", class "Lorg/apache/kafkaesqueesqueesque/common/serialization/Serializer;"); v. = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, 1); goto label; label: virtualinvoke v.("key.serializer"); v. = v; label: if v != null goto label; v = virtualinvoke v.("value.serializer", class "Lorg/apache/kafkaesqueesqueesque/common/serialization/Serializer;"); v. = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, 0); goto label; label: virtualinvoke v.("value.serializer"); v. = v; label: v = v.; interfaceinvoke v.("client.id", v); v = new org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; specialinvoke v.(java.util.Map,boolean)>(v, 0); v = virtualinvoke v.("interceptor.classes", class "Lorg/apache/kafkaesqueesqueesque/clients/producer/ProducerInterceptor;"); if v == null goto label; v. = v; goto label; label: v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors; specialinvoke v.(java.util.List)>(v); v. = v; label: v = newarray (java.util.List)[2]; v[0] = v; v[1] = v; v = specialinvoke v.(v, v, v); v = virtualinvoke v.("max.request.size"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("buffer.memory"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("compression.type"); v = staticinvoke (v); v. = v; v = virtualinvoke v.("max.block.ms"); v = virtualinvoke v.(); v. = v; v = v.; v = staticinvoke (v, v); v = new org.apache.kafkaesqueesqueesque.clients.ApiVersions; specialinvoke v.()>(); v. = v; v = specialinvoke v.(v, v); v. = v; v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator; v = virtualinvoke v.("batch.size"); v = virtualinvoke v.(); v = v.; v = staticinvoke (v); v = v.; v = v.; v = v.; v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.BufferPool; v = v.; v = virtualinvoke v.("batch.size"); v = virtualinvoke v.(); v = v.; specialinvoke v.(long,int,org.apache.kafkaesqueesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesqueesque.common.utils.Time,java.lang.String)>(v, v, v, v, "producer-metrics"); specialinvoke v.(org.apache.kafkaesqueesqueesque.common.utils.LogContext,int,org.apache.kafkaesqueesqueesque.common.record.CompressionType,int,long,int,org.apache.kafkaesqueesqueesque.common.metrics.Metrics,java.lang.String,org.apache.kafkaesqueesqueesque.common.utils.Time,org.apache.kafkaesqueesqueesque.clients.ApiVersions,org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager,org.apache.kafkaesqueesqueesque.clients.producer.internals.BufferPool)>(v, v, v, v, v, v, v, "producer-metrics", v, v, v, v); v. = v; v = virtualinvoke v.("bootstrap.servers"); v = virtualinvoke v.("client.dns.lookup"); v = staticinvoke (v, v); if v == null goto label; v. = v; goto label; label: v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata; v = virtualinvoke v.("metadata.max.age.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("metadata.max.idle.ms"); v = virtualinvoke v.(); v = ; specialinvoke v.(long,long,long,org.apache.kafkaesqueesqueesque.common.utils.LogContext,org.apache.kafkaesqueesqueesque.common.internals.ClusterResourceListeners,org.apache.kafkaesqueesqueesque.common.utils.Time)>(v, v, v, v, v, v); v. = v; v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.("errors"); v. = v; v = v.; v = virtualinvoke v.(v, v, v); v. = v; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("kafka-producer-network-thread | \u0001"); v = new org.apache.kafkaesqueesqueesque.common.utils.KafkaThread; v = v.; specialinvoke v.(java.lang.String,java.lang.Runnable,boolean)>(v, v, 1); v. = v; v = v.; virtualinvoke v.(); virtualinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(); staticinvoke ("kafka.producer", v, v, v); v = v.; interfaceinvoke v.("Kafka producer started"); label: goto label; label: v := @caughtexception; v = staticinvoke (0L); specialinvoke v.(v, 1); v = new org.apache.kafkaesqueesqueesque.common.KafkaException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failed to construct kafka producer", v); throw v; label: return; catch java.lang.Throwable from label to label with label; } org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender newSender(org.apache.kafkaesqueesqueesque.common.utils.LogContext, org.apache.kafkaesqueesqueesque.clients.KafkaClient, org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata) { java.lang.Integer v, v, v, v; java.lang.Long v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; boolean v; org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; org.apache.kafkaesqueesqueesque.common.utils.Time v, v, v, v; org.apache.kafkaesqueesqueesque.common.metrics.Metrics v, v; long v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetrics v; org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v, v; short v; int v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator v; java.lang.String v, v; org.apache.kafkaesqueesqueesque.common.network.ChannelBuilder v; org.slf4j.Logger v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.SenderMetricsRegistry v, v; org.apache.kafkaesqueesqueesque.common.network.Selector v; org.apache.kafkaesqueesqueesque.clients.NetworkClient v; org.apache.kafkaesqueesqueesque.clients.ApiVersions v, v; org.apache.kafkaesqueesqueesque.common.utils.LogContext v; org.apache.kafkaesqueesqueesque.common.metrics.Sensor v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.LogContext; v := @parameter: org.apache.kafkaesqueesqueesque.clients.KafkaClient; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.("request.timeout.ms"); v = virtualinvoke v.(); v = v.; v = v.; v = staticinvoke (v, v, v); v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetrics; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.metrics.Metrics)>(v); v = v.; v = staticinvoke (v); if v == null goto label; v = v; goto label; label: v = new org.apache.kafkaesqueesqueesque.clients.NetworkClient; v = v; v = new org.apache.kafkaesqueesqueesque.common.network.Selector; v = v.; v = virtualinvoke v.("connections.max.idle.ms"); v = virtualinvoke v.(); v = v.; v = v.; specialinvoke v.(long,org.apache.kafkaesqueesqueesque.common.metrics.Metrics,org.apache.kafkaesqueesqueesque.common.utils.Time,java.lang.String,org.apache.kafkaesqueesqueesque.common.network.ChannelBuilder,org.apache.kafkaesqueesqueesque.common.utils.LogContext)>(v, v, v, "producer", v, v); v = v.; v = v.; v = virtualinvoke v.("reconnect.backoff.ms"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("reconnect.backoff.max.ms"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("send.buffer.bytes"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("receive.buffer.bytes"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("client.dns.lookup"); v = staticinvoke (v); v = v.; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.network.Selectable,org.apache.kafkaesqueesqueesque.clients.Metadata,java.lang.String,int,long,long,int,int,int,org.apache.kafkaesqueesqueesque.clients.ClientDnsLookup,org.apache.kafkaesqueesqueesque.common.utils.Time,boolean,org.apache.kafkaesqueesqueesque.clients.ApiVersions,org.apache.kafkaesqueesqueesque.common.metrics.Sensor,org.apache.kafkaesqueesqueesque.common.utils.LogContext)>(v, v, v, v, v, v, v, v, v, v, v, 1, v, v, v); label: v = v; v = v.; v = v.; v = staticinvoke (v, v); v = v.; v = v.; v = staticinvoke (v, v); v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender; v = v.; if v != 1 goto label; v = 1; goto label; label: v = 0; label: v = v.; v = virtualinvoke v.("max.request.size"); v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = virtualinvoke v.("retry.backoff.ms"); v = virtualinvoke v.(); v = v.; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.utils.LogContext,org.apache.kafkaesqueesqueesque.clients.KafkaClient,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata,org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator,boolean,int,short,int,org.apache.kafkaesqueesqueesque.clients.producer.internals.SenderMetricsRegistry,org.apache.kafkaesqueesqueesque.common.utils.Time,int,long,org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager,org.apache.kafkaesqueesqueesque.clients.ApiVersions)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v); return v; } private static int lingerMs(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig) { java.lang.Long v; long v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v = virtualinvoke v.("linger.ms"); v = virtualinvoke v.(); v = staticinvoke (v, 2147483647L); return v; } private static int configureDeliveryTimeout(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig, org.slf4j.Logger) { java.lang.Object[] v; org.slf4j.Logger v; long v, v; java.lang.Integer v, v, v; org.apache.kafkaesqueesqueesque.common.config.ConfigException v; java.util.Map v; int v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; boolean v; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v := @parameter: org.slf4j.Logger; v = virtualinvoke v.("delivery.timeout.ms"); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.("request.timeout.ms"); v = virtualinvoke v.(); v = v + v; v = staticinvoke (v, 2147483647L); if v >= v goto label; v = virtualinvoke v.(); v = interfaceinvoke v.("delivery.timeout.ms"); if v == 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.config.ConfigException; specialinvoke v.(java.lang.String)>("delivery.timeout.ms should be equal to or larger than linger.ms + request.timeout.ms"); throw v; label: v = v; v = newarray (java.lang.Object)[4]; v[0] = "delivery.timeout.ms"; v[1] = "linger.ms"; v[2] = "request.timeout.ms"; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("{} should be equal to or larger than {} + {}. Setting it to {}.", v); label: return v; } private org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager configureTransactionState(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig, org.apache.kafkaesqueesqueesque.common.utils.LogContext) { long v; java.lang.Integer v; java.lang.Long v; java.util.Map v, v; int v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; java.lang.String v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; boolean v, v, v, v; org.slf4j.Logger v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v, v; org.apache.kafkaesqueesqueesque.clients.ApiVersions v; org.apache.kafkaesqueesqueesque.common.utils.LogContext v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.LogContext; v = null; v = virtualinvoke v.(); v = interfaceinvoke v.("enable.idempotence"); v = virtualinvoke v.(); v = interfaceinvoke v.("transactional.id"); if v == 0 goto label; if v != 0 goto label; v = v.; interfaceinvoke v.("Overriding the default {} to true since {} is specified.", "enable.idempotence", "transactional.id"); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("transactional.id"); v = virtualinvoke v.("transaction.timeout.ms"); v = virtualinvoke v.(); v = virtualinvoke v.("retry.backoff.ms"); v = virtualinvoke v.(); v = new org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.common.utils.LogContext,java.lang.String,int,long,org.apache.kafkaesqueesqueesque.clients.ApiVersions)>(v, v, v, v, v); v = v; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("Instantiated a transactional producer."); goto label; label: v = v.; interfaceinvoke v.("Instantiated an idempotent producer."); label: return v; } private static int configureRetries(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig, org.slf4j.Logger) { org.slf4j.Logger v; java.lang.Integer v, v; java.util.Map v; int v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; boolean v, v; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v := @parameter: org.slf4j.Logger; v = virtualinvoke v.(); v = interfaceinvoke v.("retries"); v = virtualinvoke v.(); if v == 0 goto label; if v != 0 goto label; v = staticinvoke (2147483647); interfaceinvoke v.("Overriding the default retries config to the recommended value of {} since the idempotent producer is enabled.", v); label: v = virtualinvoke v.("retries"); v = virtualinvoke v.(); return v; } private static int configureInflightRequests(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig) { org.apache.kafkaesqueesqueesque.common.config.ConfigException v; int v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; java.lang.Integer v, v; boolean v; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("max.in.flight.requests.per.connection"); v = virtualinvoke v.(); if 5 >= v goto label; v = new org.apache.kafkaesqueesqueesque.common.config.ConfigException; specialinvoke v.(java.lang.String)>("Must set max.in.flight.requests.per.connection to at most 5 to use the idempotent producer."); throw v; label: v = virtualinvoke v.("max.in.flight.requests.per.connection"); v = virtualinvoke v.(); return v; } private static short configureAcks(org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig, org.slf4j.Logger) { org.slf4j.Logger v; org.apache.kafkaesqueesqueesque.common.config.ConfigException v; short v; java.util.Map v; int v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v; java.lang.String v; boolean v, v; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig; v := @parameter: org.slf4j.Logger; v = virtualinvoke v.(); v = interfaceinvoke v.("acks"); v = virtualinvoke v.("acks"); v = staticinvoke (v); v = virtualinvoke v.(); if v == 0 goto label; if v != 0 goto label; interfaceinvoke v.("Overriding the default {} to all since idempotence is enabled.", "acks"); goto label; label: v = (int) -1; if v == v goto label; v = new org.apache.kafkaesqueesqueesque.common.config.ConfigException; specialinvoke v.(java.lang.String)>("Must set acks to all in order to use the idempotent producer. Otherwise we cannot guarantee idempotence."); throw v; label: return v; } public void initTransactions() { java.util.concurrent.TimeUnit v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; long v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; specialinvoke v.(); specialinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = ; virtualinvoke v.(v, v); return; } public void beginTransaction() throws org.apache.kafkaesqueesqueesque.common.errors.ProducerFencedException { org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; specialinvoke v.(); specialinvoke v.(); v = v.; virtualinvoke v.(); return; } public void sendOffsetsToTransaction(java.util.Map, java.lang.String) throws org.apache.kafkaesqueesqueesque.common.errors.ProducerFencedException { org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata v; java.util.Map v; java.lang.String v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v = new org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v, v); return; } public void sendOffsetsToTransaction(java.util.Map, org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata) throws org.apache.kafkaesqueesqueesque.common.errors.ProducerFencedException { org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult v; org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata v; java.util.Map v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata; specialinvoke v.(v); specialinvoke v.(); specialinvoke v.(); v = v.; v = virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); virtualinvoke v.(); return; } public void commitTransaction() throws org.apache.kafkaesqueesqueesque.common.errors.ProducerFencedException { java.util.concurrent.TimeUnit v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; long v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; specialinvoke v.(); specialinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = ; virtualinvoke v.(v, v); return; } public void abortTransaction() throws org.apache.kafkaesqueesqueesque.common.errors.ProducerFencedException { java.util.concurrent.TimeUnit v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v; long v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; specialinvoke v.(); specialinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = ; virtualinvoke v.(v, v); return; } public java.util.concurrent.Future send(org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord) { java.util.concurrent.Future v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord; v = virtualinvoke v.(v, null); return v; } public java.util.concurrent.Future send(org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord, org.apache.kafkaesqueesqueesque.clients.producer.Callback) { java.util.concurrent.Future v; org.apache.kafkaesqueesqueesque.clients.producer.Callback v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.Callback; v = v.; v = virtualinvoke v.(v); v = specialinvoke v.(v, v); return v; } private void throwIfProducerClosed() { java.lang.IllegalStateException v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; boolean v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v, v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot perform operation after producer has been closed"); throw v; label: return; } private java.util.concurrent.Future doSend(org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord, org.apache.kafkaesqueesqueesque.clients.producer.Callback) { byte[] v, v; org.apache.kafkaesqueesqueesque.common.errors.InterruptException v; java.lang.Integer v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.errors.ApiException v; byte v; java.lang.Long v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerMetadata v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer$FutureFailure v; org.apache.kafkaesqueesqueesque.common.KafkaException v, v, v; java.lang.Exception v; org.apache.kafkaesqueesqueesque.clients.producer.internals.Sender v; org.apache.kafkaesqueesqueesque.common.utils.Time v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer$ClusterAndWaitTime v; java.lang.Object[] v, v; long v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.FutureRecordMetadata v; java.lang.ClassCastException v, v; org.apache.kafkaesqueesqueesque.clients.producer.ProducerConfig v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.ApiVersions v; org.apache.kafkaesqueesqueesque.common.TopicPartition v, v, v; org.apache.kafkaesqueesqueesque.common.metrics.Sensor v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.header.Header[] v; org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator$RecordAppendResult v; org.apache.kafkaesqueesqueesque.common.errors.SerializationException v, v; org.apache.kafkaesqueesqueesque.common.header.Headers v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.BufferExhaustedException v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer v; boolean v, v, v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.common.Cluster v; org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer$InterceptorCallback v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v, v, v, v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.Partitioner v; org.apache.kafkaesqueesqueesque.common.record.CompressionType v; org.apache.kafkaesqueesqueesque.clients.producer.Callback v; org.apache.kafkaesqueesqueesque.common.metrics.Metrics v; int v, v, v; org.apache.kafkaesqueesqueesque.clients.producer.internals.RecordAccumulator v, v; org.slf4j.Logger v, v, v, v, v, v; java.lang.InterruptedException v; java.lang.Class v, v, v, v; java.lang.Object v, v, v, v; org.apache.kafkaesqueesqueesque.common.serialization.Serializer v, v; v := @this: org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord; v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.Callback; v = null; label: specialinvoke v.(); v = v.; v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = specialinvoke v.(v, v, v, v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.kafkaesqueesqueesque.common.KafkaException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Producer closed while send in progress", v); throw v; label: throw v; label: v = v.; v = v + v; v = v.; v = v.; v = v - v; v = staticinvoke (0L, v); v = v.; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.kafkaesqueesqueesque.common.errors.SerializationException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("key.serializer"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Can\'t convert key of class \u to class \u specified in key.serializer"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.kafkaesqueesqueesque.common.errors.SerializationException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.("value.serializer"); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Can\'t convert value of class \u to class \u specified in value.serializer"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = specialinvoke v.(v, v, v, v); v = new org.apache.kafkaesqueesqueesque.common.TopicPartition; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,int)>(v, v); v = v; v = virtualinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = staticinvoke (v, v, v, v, v); specialinvoke v.(v); v = virtualinvoke v.(); if v != null goto label; v = v; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = v; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v = virtualinvoke v.(); v[2] = v; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("Attempting to append record {} with callback {} to topic {} partition {}", v); label: v = new org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer$InterceptorCallback; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.clients.producer.Callback,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.TopicPartition)>(v, v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(v, v, v, v, v, v, v, 1, v); v = v.; if v == 0 goto label; v = v; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); v = specialinvoke v.(v, v, v, v); v = new org.apache.kafkaesqueesqueesque.common.TopicPartition; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,int)>(v, v); v = v; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Retrying append due to new batch creation for topic {} partition {}. The old partition was {}", v); label: v = new org.apache.kafkaesqueesqueesque.clients.producer.KafkaProducer$InterceptorCallback; v = v.; specialinvoke v.(org.apache.kafkaesqueesqueesque.clients.producer.Callback,org.apache.kafkaesqueesqueesque.clients.producer.internals.ProducerInterceptors,org.apache.kafkaesqueesqueesque.common.TopicPartition)>(v, v, v); v = v.; v = virtualinvoke v.(v, v, v, v, v, v, v, 0, v); label: v = v.; if v == null goto label; v = v.