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, boolean isCpcEnabled)

Method Summary

Modifier and Type	Method	Description
void	recordStatsIn(org.apache.kafka.common.TopicPartition tp, Optional<io.confluent.kafka.common.StorageClass> storageClass, long bytes, long numRecords, long timeMs)
void	recordStatsOut(org.apache.kafka.common.TopicPartition tp, Optional<io.confluent.kafka.common.StorageClass> storageClass, long bytes, long numRecords, long timeMs)

Methods inherited from class 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,
 boolean isCpcEnabled)

Method Details

recordStatsIn

public void recordStatsIn(org.apache.kafka.common.TopicPartition tp,
 Optional<io.confluent.kafka.common.StorageClass> storageClass,
 long bytes,
 long numRecords,
 long timeMs)

Parameters:

storageClass - The partition topic's storage class when resolved; tags the per-partition throughput metrics. Optional.empty() leaves them un-tagged.

timeMs - The current POSIX time in milliseconds

recordStatsOut

public void recordStatsOut(org.apache.kafka.common.TopicPartition tp,
 Optional<io.confluent.kafka.common.StorageClass> storageClass,
 long bytes,
 long numRecords,
 long timeMs)

Parameters:

storageClass - The partition topic's storage class when resolved; tags the per-partition throughput metrics. Optional.empty() leaves them un-tagged.

timeMs - The current POSIX time in milliseconds