public interface RebalanceStep
AbstractGoal.rebalanceForBroker(com.linkedin.kafka.cruisecontrol.model.Broker, com.linkedin.kafka.cruisecontrol.model.ClusterModel, java.util.Set<com.linkedin.kafka.cruisecontrol.analyzer.goals.Goal>, com.linkedin.kafka.cruisecontrol.analyzer.OptimizationOptions)
operation (like leader balancing, replica balancing,
partition balancing etc). This allows different aspect of balancing to be separated out in
their own class and thus makes them easier to understand.Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
Modifier and Type | Method and Description |
---|---|
default boolean |
balance()
Moves replica around to satisfy the goal.The handler may have updated the cluster
model with replica resassignment even if it cannot fully satisfy the goal.
|
boolean |
doBalance()
Moves replica around to satisfy the goal.
|
default RebalanceStep |
onFailureThen(RebalanceStep nextHandler) |
default boolean balance()
boolean doBalance()
default RebalanceStep onFailureThen(RebalanceStep nextHandler)