Class PartitionSensors

java.lang.Object

io.confluent.kafka.multitenant.metrics.PartitionSensors

public class PartitionSensors
extends Object

Constructor Summary

Constructors

Constructor	Description
PartitionSensors(TenantMetrics.MetricsRequestContext context, org.apache.kafka.common.metrics.Metrics metrics, PartitionSensorBuilder sensorBuilder)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionSensors

public PartitionSensors(TenantMetrics.MetricsRequestContext context,
 org.apache.kafka.common.metrics.Metrics metrics,
 PartitionSensorBuilder sensorBuilder)

Method Details

recordStatsIn

public void recordStatsIn(org.apache.kafka.common.TopicPartition tp,
 long bytes,
 long numRecords,
 long timeMs)

Parameters:

timeMs - The current POSIX time in milliseconds

recordStatsOut

public void recordStatsOut(org.apache.kafka.common.TopicPartition tp,
 long bytes,
 long numRecords,
 long timeMs)