public class KafkaCruiseControlContext extends Object
Constructor and Description |
---|
KafkaCruiseControlContext(Integer brokerId,
KafkaCruiseControlConfig config,
org.apache.kafka.common.utils.Time time,
KafkaCruiseControl.CcStartupMode startupMode) |
Modifier and Type | Method and Description |
---|---|
EvenClusterLoadStateManager |
getActiveEvenClusterLoadStateManager()
Returns instance of active
EvenClusterLoadStateManager used in registering events to
the even cluster load state machine. |
Integer |
getBrokerId() |
KafkaCruiseControlConfig |
getConfig() |
EvenClusterLoadStateManager |
getCurrentEvenClusterLoadStateManager()
Returns the current even cluster load manager that is used to fetch status in
ConfluentDataBalanceEngine.evenClusterLoadStatus(KafkaConfig) |
EvenClusterLoadStateManager |
getDisabledEvenClusterLoadStateManager()
Returns instance of disabled EvenClusterLoadManager used when self healing is disabled for
for GOAL_VIOLATION anomaly type.
|
KafkaCruiseControl.CcStartupMode |
getStartupMode() |
org.apache.kafka.common.utils.Time |
getTime() |
void |
setCurrentEvenClusterLoadStateManager(EvenClusterLoadStateManager currentEvenClusterLoadStateManager)
Sets the current even cluster load manager during start up and when self healing is
enabled/disabled for GOAL_VIOLATION anomaly type
|
void |
setUpEvenClusterLoadStateManagers(EvenClusterLoadStateManager activeEvenClusterLoadStateManager,
EvenClusterLoadStateManager disabledEvenClusterLoadStateManager)
Sets instances of
EvenClusterLoadStateManager created in
AnomalyDetector to handle requests when
self healing is enabled/disabled for GOAL_VIOLATION anomaly type. |
public KafkaCruiseControlContext(Integer brokerId, KafkaCruiseControlConfig config, org.apache.kafka.common.utils.Time time, KafkaCruiseControl.CcStartupMode startupMode)
public Integer getBrokerId()
public KafkaCruiseControl.CcStartupMode getStartupMode()
public KafkaCruiseControlConfig getConfig()
public org.apache.kafka.common.utils.Time getTime()
public void setUpEvenClusterLoadStateManagers(EvenClusterLoadStateManager activeEvenClusterLoadStateManager, EvenClusterLoadStateManager disabledEvenClusterLoadStateManager)
EvenClusterLoadStateManager
created in
AnomalyDetector
to handle requests when
self healing is enabled/disabled for GOAL_VIOLATION anomaly type.public EvenClusterLoadStateManager getActiveEvenClusterLoadStateManager()
EvenClusterLoadStateManager
used in registering events to
the even cluster load state machine.public EvenClusterLoadStateManager getDisabledEvenClusterLoadStateManager()
public void setCurrentEvenClusterLoadStateManager(EvenClusterLoadStateManager currentEvenClusterLoadStateManager)
public EvenClusterLoadStateManager getCurrentEvenClusterLoadStateManager()
ConfluentDataBalanceEngine.evenClusterLoadStatus(KafkaConfig)