public class PartitionSensors
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
PARTITION_TAG |
static java.lang.String |
TOPIC_TAG |
Constructor and Description |
---|
PartitionSensors(TenantMetrics.MetricsRequestContext context,
java.util.Map<java.lang.String,org.apache.kafka.common.metrics.Sensor> sensors,
PartitionSensorBuilder sensorBuilder,
boolean enablePartitionPercentilesMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
recordStatsIn(org.apache.kafka.common.TopicPartition tp,
long bytes,
long numRecords,
long timeMs) |
void |
recordStatsOut(org.apache.kafka.common.TopicPartition tp,
long bytes,
long numRecords,
long timeMs) |
public static final java.lang.String TOPIC_TAG
public static final java.lang.String PARTITION_TAG
public PartitionSensors(TenantMetrics.MetricsRequestContext context, java.util.Map<java.lang.String,org.apache.kafka.common.metrics.Sensor> sensors, PartitionSensorBuilder sensorBuilder, boolean enablePartitionPercentilesMetrics)
public void recordStatsIn(org.apache.kafka.common.TopicPartition tp, long bytes, long numRecords, long timeMs)
timeMs
- The current POSIX time in millisecondspublic void recordStatsOut(org.apache.kafka.common.TopicPartition tp, long bytes, long numRecords, long timeMs)