public class BrokerLoad extends Object
Constructor and Description |
---|
BrokerLoad() |
Modifier and Type | Method and Description |
---|---|
double |
brokerMetric(RawMetricType rawMetricType) |
boolean |
brokerMetricAvailable(RawMetricType rawMetricType) |
double |
diskUsage() |
boolean |
minRequiredBrokerMetricsAvailable() |
Set<RawMetricType> |
missingBrokerMetricsInMinSupportedVersion() |
double |
partitionMetric(String topic,
int partition,
RawMetricType rawMetricType) |
void |
prepareBrokerMetrics(org.apache.kafka.common.Cluster cluster,
int brokerId,
long time)
Due to the yammer metric exponential decaying mechanism, the broker metric and the sum of the partition metrics
on the same broker may differ by a lot.
|
void |
recordMetric(CruiseControlMetric ccm) |
void |
setTopicMetrics(String topic,
RawMetricType rawMetricType,
double newValue,
long time) |
double |
topicMetrics(String topic,
RawMetricType rawMetricType) |
double |
topicMetrics(String topic,
RawMetricType rawMetricType,
boolean convertUnit) |
boolean |
topicMetricsAvailable(String topic) |
public void recordMetric(CruiseControlMetric ccm)
public boolean topicMetricsAvailable(String topic)
public boolean minRequiredBrokerMetricsAvailable()
public boolean brokerMetricAvailable(RawMetricType rawMetricType)
public Set<RawMetricType> missingBrokerMetricsInMinSupportedVersion()
public double brokerMetric(RawMetricType rawMetricType)
public double topicMetrics(String topic, RawMetricType rawMetricType)
public double topicMetrics(String topic, RawMetricType rawMetricType, boolean convertUnit)
public void setTopicMetrics(String topic, RawMetricType rawMetricType, double newValue, long time)
public double partitionMetric(String topic, int partition, RawMetricType rawMetricType)
public void prepareBrokerMetrics(org.apache.kafka.common.Cluster cluster, int brokerId, long time)
cluster
- The Kafka cluster.brokerId
- The broker id to prepare metrics for.time
- The last sample time.public double diskUsage()