public class MonitorUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static double |
UNIT_INTERVAL_TO_PERCENTAGE |
Modifier and Type | Method and Description |
---|---|
static ModelCompletenessRequirements |
combineLoadRequirementOptions(java.util.Collection<Goal> goals) |
static boolean |
ensureNoPartitionUnderPartitionReassignment(kafka.zk.KafkaZkClient kafkaZkClient)
Check whether there are ongoing partition reassignments and wait for the reassignments to finish.
|
static java.lang.String |
getRackHandleNull(org.apache.kafka.common.Node node) |
static boolean |
metadataChanged(MetadataClient.ClusterAndPlacements prev,
MetadataClient.ClusterAndPlacements curr)
Check whether the metadata has changed.
|
static int |
totalNumPartitions(org.apache.kafka.common.Cluster cluster) |
public static final double UNIT_INTERVAL_TO_PERCENTAGE
public static boolean metadataChanged(MetadataClient.ClusterAndPlacements prev, MetadataClient.ClusterAndPlacements curr)
public static ModelCompletenessRequirements combineLoadRequirementOptions(java.util.Collection<Goal> goals)
public static int totalNumPartitions(org.apache.kafka.common.Cluster cluster)
public static boolean ensureNoPartitionUnderPartitionReassignment(kafka.zk.KafkaZkClient kafkaZkClient)
kafkaZkClient
- the KafkaZkClient class used to check ongoing partition reassignments.public static java.lang.String getRackHandleNull(org.apache.kafka.common.Node node)
node
- The node whose rack is requested.