Class HotPartitionSensors

java.lang.Object

io.confluent.kafka.multitenant.metrics.HotPartitionSensors

public class HotPartitionSensors
extends Object

Helper class to create and access the hot partition sensors for a TopicPartition.

Constructor Summary

Constructors

Constructor	Description
HotPartitionSensors(TenantMetrics.TenantMetricsContext context, org.apache.kafka.common.metrics.Metrics metrics, HotPartitionSensorBuilder hotPartitionSensorBuilder)

Method Summary

Modifier and Type	Method	Description
void	recordHotPartitionIn(org.apache.kafka.common.TopicPartition tp, long currentTimeMs)	Marks the given partition as hot ingress-wise at the given timestamp.
void	recordHotPartitionOut(org.apache.kafka.common.TopicPartition tp, long currentTimeMs)	Marks the given partition as hot egress-wise at the given timestamp.

Methods inherited from class java.lang.Object

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

Constructor Details

HotPartitionSensors

public HotPartitionSensors(TenantMetrics.TenantMetricsContext context,
 org.apache.kafka.common.metrics.Metrics metrics,
 HotPartitionSensorBuilder hotPartitionSensorBuilder)

Method Details

recordHotPartitionIn

public void recordHotPartitionIn(org.apache.kafka.common.TopicPartition tp,
 long currentTimeMs)

Marks the given partition as hot ingress-wise at the given timestamp.

recordHotPartitionOut

public void recordHotPartitionOut(org.apache.kafka.common.TopicPartition tp,
 long currentTimeMs)

Marks the given partition as hot egress-wise at the given timestamp.