public interface PlanComputable
Modifier and Type | Method and Description |
---|---|
OptimizerResult |
compute()
Compute a reassignment plan
|
OptimizerResult compute() throws Exception
org.apache.kafka.common.errors.InsufficientRebalancePlanMetricsException
- - in case there aren't enough metrics to compute the planNotEnoughValidWindowsException
- - in case there aren't enough metrics to compute the plan
It is up to the implementor to decide which exception to throw, but #NotEnoughValidWindowsException
is preferred for internal SBK operations and
#InsufficientRebalancePlanMetricsException
is preferred when the exception is meant to be surfaced to a userException
- - any other unexpected errors