public class MonitorUtils extends Object
Modifier and Type | Field and Description |
---|---|
static double |
UNIT_INTERVAL_TO_PERCENTAGE |
Modifier and Type | Method and Description |
---|---|
static String |
getRackHandleNull(org.apache.kafka.common.Node node) |
static boolean |
metadataChanged(MetadataClient.ClusterMetadata prev,
MetadataClient.ClusterMetadata 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.ClusterMetadata prev, MetadataClient.ClusterMetadata curr)
public static int totalNumPartitions(org.apache.kafka.common.Cluster cluster)
public static String getRackHandleNull(org.apache.kafka.common.Node node)
node
- The node whose rack is requested.