public class NoOpEvenClusterLoadStateManager extends Object implements EvenClusterLoadStateManager
EvenClusterLoadStateMachine.EvenClusterLoadState.DISABLED
.Constructor and Description |
---|
NoOpEvenClusterLoadStateManager() |
Modifier and Type | Method and Description |
---|---|
EvenClusterLoadStateMachine.EvenClusterLoadState |
currentState() |
kafka.common.EvenClusterLoadStatusDescriptionInternal |
evenClusterLoadStatusDescription() |
void |
noGoalViolationsFound() |
void |
registerEvent(EvenClusterLoadStateMachine.EvenClusterLoadEvent event)
Registers a new #
BalancerOperationEvent as part of the progress changing |
void |
registerEvent(EvenClusterLoadStateMachine.EvenClusterLoadEvent event,
Exception e)
Registers a new errorful #
BalancerOperationEvent as part of the progress changing |
void |
startRebalancing() |
public EvenClusterLoadStateMachine.EvenClusterLoadState currentState()
public void registerEvent(EvenClusterLoadStateMachine.EvenClusterLoadEvent event, Exception e)
BalancerOperationCallback
BalancerOperationEvent
as part of the progress changingpublic void registerEvent(EvenClusterLoadStateMachine.EvenClusterLoadEvent event)
BalancerOperationCallback
BalancerOperationEvent
as part of the progress changingpublic void noGoalViolationsFound()
noGoalViolationsFound
in interface EvenClusterLoadStateManager
public void startRebalancing()
startRebalancing
in interface EvenClusterLoadStateManager
public kafka.common.EvenClusterLoadStatusDescriptionInternal evenClusterLoadStatusDescription()
evenClusterLoadStatusDescription
in interface EvenClusterLoadStateManager