public class PartitionSensors extends Object
Constructor and Description |
---|
PartitionSensors(TenantMetrics.MetricsRequestContext context,
org.apache.kafka.common.metrics.Metrics metrics,
PartitionSensorBuilder sensorBuilder) |
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 PartitionSensors(TenantMetrics.MetricsRequestContext context, org.apache.kafka.common.metrics.Metrics metrics, PartitionSensorBuilder sensorBuilder)
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)