public class PlanComputationUtils extends Object
Constructor and Description |
---|
PlanComputationUtils(KafkaCruiseControlConfig config,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
OptimizerResult |
generatePlanWithRetries(PlanComputable computable,
String planDescription)
Computes a reassignments plan, retrying in the case of insufficient metrics
in the hopes of eventually collecting them
|
public PlanComputationUtils(KafkaCruiseControlConfig config, org.apache.kafka.common.utils.Time time)
public OptimizerResult generatePlanWithRetries(PlanComputable computable, String planDescription) throws Exception
computable
- - the interface used to do the actual plan computationplanDescription
- - an operator-friendly string to describe the plan we're computingException