public class HotPartitionsInfo extends Object
Constructor and Description |
---|
HotPartitionsInfo(Map<Integer,List<org.apache.kafka.common.TopicPartition>> hotPartitionsByBroker,
Set<Replica> saturatedReplicas,
double maxReplicaLoad) |
Modifier and Type | Method and Description |
---|---|
Map<Integer,List<org.apache.kafka.common.TopicPartition>> |
hotPartitionsByBroker()
For each broker, stores the TopicPartitions currently hosted by the broker which are "hot" for given resource,
i.e.
|
double |
maxReplicaLoad()
The maximum load for given resource over all replicas
|
Set<Replica> |
saturatedReplicas()
The set of all replicas which are "saturated" for given resource,
i.e.
|
int |
totalNumHotPartitions()
The total number of partitions with replicas which are "hot" for given resource
|
public Map<Integer,List<org.apache.kafka.common.TopicPartition>> hotPartitionsByBroker()
public Set<Replica> saturatedReplicas()
public double maxReplicaLoad()
public int totalNumHotPartitions()