class org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics extends java.lang.Object
{
private final org.apache.kafkaesque.common.metrics.Metrics metrics;
private org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry;
private final org.apache.kafkaesque.common.metrics.Sensor bytesFetched;
private final org.apache.kafkaesque.common.metrics.Sensor recordsFetched;
private final org.apache.kafkaesque.common.metrics.Sensor fetchLatency;
private final org.apache.kafkaesque.common.metrics.Sensor recordsFetchLag;
private final org.apache.kafkaesque.common.metrics.Sensor recordsFetchLead;
private int assignmentId;
private java.util.Set assignedPartitions;
private void <init>(org.apache.kafkaesque.common.metrics.Metrics, org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry)
{
org.apache.kafkaesque.common.metrics.stats.Avg v, v, v;
java.util.Set v;
org.apache.kafkaesque.common.MetricName v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry v;
org.apache.kafkaesque.common.metrics.stats.Max v, v, v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v, v;
org.apache.kafkaesque.common.metrics.stats.Min v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
java.lang.String[] v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.MetricNameTemplate v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.stats.WindowedCount v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: int assignmentId> = 0;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Set assignedPartitions> = v;
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics> = v;
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("bytes-fetched");
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesFetched> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesFetched>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchSizeAvg>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesFetched>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchSizeMax>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesFetched>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate bytesConsumedRate>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate bytesConsumedTotal>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("records-fetched");
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetched> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetched>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate recordsPerRequestAvg>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetched>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate recordsConsumedRate>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate recordsConsumedTotal>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("fetch-latency");
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor fetchLatency> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor fetchLatency>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchLatencyAvg>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor fetchLatency>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchLatencyMax>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor fetchLatency>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchRequestRate>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate fetchRequestTotal>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.metrics.stats.SampledStat,org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("records-lag");
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLag> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLag>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate recordsLagMax>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("records-lead");
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLead> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLead>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate recordsLeadMin>;
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Min;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Min: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
return;
}
private void recordTopicFetchMetrics(java.lang.String, int, int)
{
org.apache.kafkaesque.common.metrics.stats.Max v;
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v;
org.apache.kafkaesque.common.metrics.stats.Avg v, v;
org.apache.kafkaesque.common.MetricName v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.metrics.Metrics v, v, v, v, v, v, v, v, v, v, v;
java.util.HashMap v;
org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry v, v, v, v, v, v, v;
org.apache.kafkaesque.common.MetricNameTemplate v, v, v, v, v, v, v;
int v, v;
java.lang.String v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
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[])>("topic.\u.bytes-fetched");
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String replace(char,char)>(46, 95);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("topic", v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicFetchSizeAvg>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicFetchSizeMax>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicBytesConsumedRate>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicBytesConsumedTotal>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
label:
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("topic.\u.records-fetched");
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int)>(1);
v = virtualinvoke v.<java.lang.String: java.lang.String replace(char,char)>(46, 95);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("topic", v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicRecordsPerRequestAvg>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicRecordsConsumedRate>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate topicRecordsConsumedTotal>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
label:
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
return;
}
private void maybeUpdateAssignment(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState)
{
org.apache.kafkaesque.common.metrics.Gauge v;
org.apache.kafkaesque.common.metrics.Metrics v, v, v, v, v;
org.apache.kafkaesque.common.metrics.KafkaMetric v;
int v, v;
java.lang.String v, v;
boolean v, v, v, v;
java.util.Iterator v, v;
java.util.Set v, v, v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
org.apache.kafkaesque.common.MetricName v, v;
org.apache.kafkaesque.clients.consumer.internals.SubscriptionState v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.SubscriptionState;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: int assignmentId()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: int assignmentId>;
if v == v goto label;
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.SubscriptionState: java.util.Set assignedPartitions()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Set assignedPartitions>;
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.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.lang.String partitionLagMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void removeSensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.lang.String partitionLeadMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void removeSensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.MetricName partitionPreferredReadReplicaMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.KafkaMetric removeMetric(org.apache.kafkaesque.common.MetricName)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Set assignedPartitions>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.MetricName partitionPreferredReadReplicaMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.KafkaMetric metric(org.apache.kafkaesque.common.MetricName)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics$lambda_maybeUpdateAssignment_0__200: org.apache.kafkaesque.common.metrics.Gauge bootstrap$(org.apache.kafkaesque.clients.consumer.internals.SubscriptionState,org.apache.kafkaesque.common.TopicPartition)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void addMetric(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider)>(v, v);
goto label;
label:
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Set assignedPartitions> = v;
v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: int assignmentId> = v;
label:
return;
}
private void recordPartitionLead(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.common.metrics.Metrics v, v, v, v, v;
long v;
org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry v, v, v;
java.util.Map v;
org.apache.kafkaesque.common.MetricNameTemplate v, v, v;
java.lang.String v;
org.apache.kafkaesque.common.metrics.stats.Avg v;
org.apache.kafkaesque.common.metrics.stats.Min v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
org.apache.kafkaesque.common.metrics.stats.Value v;
org.apache.kafkaesque.common.MetricName v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLead>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.lang.String partitionLeadMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Map topicPartitionTags(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLead>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Value;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Value: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLeadMin>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Min;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Min: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLeadAvg>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
label:
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
return;
}
private void recordPartitionLag(org.apache.kafkaesque.common.TopicPartition, long)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.TopicPartition v;
org.apache.kafkaesque.common.metrics.Metrics v, v, v, v, v;
long v;
org.apache.kafkaesque.common.metrics.stats.Max v;
org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry v, v, v;
java.util.Map v;
org.apache.kafkaesque.common.MetricNameTemplate v, v, v;
java.lang.String v;
org.apache.kafkaesque.common.metrics.stats.Avg v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
org.apache.kafkaesque.common.metrics.stats.Value v;
org.apache.kafkaesque.common.MetricName v, v, v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: long;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsFetchLag>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
v = staticinvoke <org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.lang.String partitionLagMetricName(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Map topicPartitionTags(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLag>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Value;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Value: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLagMax>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionRecordsLagAvg>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
label:
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
return;
}
private static java.lang.String partitionLagMetricName(org.apache.kafkaesque.common.TopicPartition)
{
java.lang.String v;
org.apache.kafkaesque.common.TopicPartition v;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.common.TopicPartition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.records-lag");
return v;
}
private static java.lang.String partitionLeadMetricName(org.apache.kafkaesque.common.TopicPartition)
{
java.lang.String v;
org.apache.kafkaesque.common.TopicPartition v;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.common.TopicPartition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.records-lead");
return v;
}
private org.apache.kafkaesque.common.MetricName partitionPreferredReadReplicaMetricName(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry v;
org.apache.kafkaesque.common.MetricName v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.Map v;
org.apache.kafkaesque.common.MetricNameTemplate v;
org.apache.kafkaesque.common.metrics.Metrics v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: java.util.Map topicPartitionTags(org.apache.kafkaesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics: org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry metricsRegistry>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.FetcherMetricsRegistry: org.apache.kafkaesque.common.MetricNameTemplate partitionPreferredReadReplica>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricInstance(org.apache.kafkaesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
private java.util.Map topicPartitionTags(org.apache.kafkaesque.common.TopicPartition)
{
org.apache.kafkaesque.common.TopicPartition v;
int v;
java.util.HashMap v;
java.lang.String v, v, v;
org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.Fetcher$FetchManagerMetrics;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int)>(2);
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replace(char,char)>(46, 95);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("topic", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: int partition()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("partition", v);
return v;
}
}