io.confluent.kafka.multitenant.metrics

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 and Description
HotPartitionSensors(TenantMetrics.TenantMetricsContext context, org.apache.kafka.common.metrics.Metrics metrics, HotPartitionSensorBuilder hotPartitionSensorBuilder)

Method Summary

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

HotPartitionSensors

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

Method Detail

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.