public class GoalOptimizer extends Object
Constructor and Description |
---|
GoalOptimizer(KafkaCruiseControlConfig config,
DataBalancerMetricsRegistry metricsRegistry,
UpdatableSbcGoalsConfig updatableSbcGoalsConfig,
GoalOptimizationHistory goalOptimizationHistory)
Constructor for Goal Optimizer takes the goals as input.
|
Modifier and Type | Method and Description |
---|---|
OptimizerResult |
optimizations(ClusterModel clusterModel,
GoalsConfig goalsConfig,
OptimizationOptions optimizationOptions)
Depending the existence of dead/broken/decommissioned brokers in the given cluster:
(1) Re-balance: Generates proposals to update the state of the cluster to achieve a final balanced state.
|
public GoalOptimizer(KafkaCruiseControlConfig config, DataBalancerMetricsRegistry metricsRegistry, UpdatableSbcGoalsConfig updatableSbcGoalsConfig, GoalOptimizationHistory goalOptimizationHistory)
config
- The Kafka Cruise Control Configuration.public OptimizerResult optimizations(ClusterModel clusterModel, GoalsConfig goalsConfig, OptimizationOptions optimizationOptions) throws KafkaCruiseControlException
clusterModel
- The state of the cluster over which the balancing proposal will be applied. Function execution
updates the cluster state with balancing proposals.goalsConfig
- goals configuration.optimizationOptions
- the options to optimize byKafkaCruiseControlException