public static class KafkaCruiseControlContext.KafkaCruiseControlContextBuilder extends Object
Constructor and Description |
---|
KafkaCruiseControlContextBuilder() |
public static KafkaCruiseControlContext.KafkaCruiseControlContextBuilder of(Integer brokerId, KafkaCruiseControlConfig config, org.apache.kafka.common.utils.Time time, KafkaCruiseControl.CcStartupMode startupMode)
public Integer brokerId()
public KafkaCruiseControlConfig config()
public org.apache.kafka.common.utils.Time time()
public KafkaCruiseControl.CcStartupMode startupMode()
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder defaultPlanComputationOptions(PlanComputationOptions defaultPlanComputationOptions)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder computationUtils(PlanComputationUtils computationUtils)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder adminClient(org.apache.kafka.clients.admin.ConfluentAdmin adminClient)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder sbkAdminUtils(SbkAdminUtils sbkAdminUtils)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder goalOptimizer(GoalOptimizer goalOptimizer)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder loadMonitor(LoadMonitor loadMonitor)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder executor(Executor executor)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder brokerShutdownManager(BrokerShutdownManager brokerShutdownManager)
public KafkaCruiseControlContext.KafkaCruiseControlContextBuilder evenClusterLoadStateManagers(EvenClusterLoadStateManager activeEvenClusterLoadStateManager)
EvenClusterLoadStateManager
created in
AnomalyDetector
to handle requests when
self healing is enabled/disabled for GOAL_VIOLATION anomaly type.public KafkaCruiseControlContext build()