public class KafkaCruiseControlContext extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaCruiseControlContext.KafkaCruiseControlContextBuilder |
Constructor and Description |
---|
KafkaCruiseControlContext(Integer brokerId,
KafkaCruiseControlConfig config,
org.apache.kafka.common.utils.Time time,
KafkaCruiseControl.CcStartupMode startupMode,
PlanComputationOptions defaultPlanComputationOptions,
PlanComputationUtils computationUtils,
org.apache.kafka.clients.admin.ConfluentAdmin adminClient,
SbkAdminUtils sbkAdminUtils,
GoalOptimizer goalOptimizer,
LoadMonitor loadMonitor,
Executor executor,
BrokerShutdownManager brokerShutdownManager,
EvenClusterLoadStateManager activeEvenClusterLoadStateManager,
EvenClusterLoadStateManager disabledEvenClusterLoadStateManager,
EvenClusterLoadStateManager currentEvenClusterLoadStateManager) |
public KafkaCruiseControlContext(Integer brokerId, KafkaCruiseControlConfig config, org.apache.kafka.common.utils.Time time, KafkaCruiseControl.CcStartupMode startupMode, PlanComputationOptions defaultPlanComputationOptions, PlanComputationUtils computationUtils, org.apache.kafka.clients.admin.ConfluentAdmin adminClient, SbkAdminUtils sbkAdminUtils, GoalOptimizer goalOptimizer, LoadMonitor loadMonitor, Executor executor, BrokerShutdownManager brokerShutdownManager, EvenClusterLoadStateManager activeEvenClusterLoadStateManager, EvenClusterLoadStateManager disabledEvenClusterLoadStateManager, EvenClusterLoadStateManager currentEvenClusterLoadStateManager)
public Integer brokerId()
public KafkaCruiseControl.CcStartupMode startupMode()
public KafkaCruiseControlConfig config()
public void config(KafkaCruiseControlConfig newConfig)
public org.apache.kafka.common.utils.Time time()
public EvenClusterLoadStateManager activeEvenClusterLoadStateManager()
EvenClusterLoadStateManager
used in registering events to
the even cluster load state machine.public EvenClusterLoadStateManager disabledEvenClusterLoadStateManager()
public void currentEvenClusterLoadStateManager(EvenClusterLoadStateManager currentEvenClusterLoadStateManager)
public EvenClusterLoadStateManager currentEvenClusterLoadStateManager()
ConfluentDataBalanceEngine.evenClusterLoadStatus(KafkaConfig)
public PlanComputationOptions defaultPlanComputationOptions()
public PlanComputationUtils computationUtils()
public org.apache.kafka.clients.admin.ConfluentAdmin adminClient()
public SbkAdminUtils sbkAdminUtils()
public GoalOptimizer goalOptimizer()
public LoadMonitor loadMonitor()
public Executor executor()
public BrokerShutdownManager brokerShutdownManager()