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 evenClusterLoadStateManager) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.admin.ConfluentAdmin |
adminClient() |
Integer |
brokerId() |
BrokerShutdownManager |
brokerShutdownManager() |
PlanComputationUtils |
computationUtils() |
KafkaCruiseControlConfig |
config() |
void |
config(KafkaCruiseControlConfig newConfig) |
PlanComputationOptions |
defaultPlanComputationOptions() |
EvenClusterLoadStateManager |
evenClusterLoadStateManager()
Returns instance of
EvenClusterLoadStateManager used in registering events to
the even cluster load state machine. |
Executor |
executor() |
GoalOptimizer |
goalOptimizer() |
LoadMonitor |
loadMonitor() |
SbkAdminUtils |
sbkAdminUtils() |
KafkaCruiseControl.CcStartupMode |
startupMode() |
org.apache.kafka.common.utils.Time |
time() |
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 evenClusterLoadStateManager)
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 evenClusterLoadStateManager()
EvenClusterLoadStateManager
used in registering events to
the even cluster load state machine.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()