public class KafkaCruiseControlContext extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaCruiseControlContext.KafkaCruiseControlContextBuilder |
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. |
Pattern |
excludedTopicsPattern()
Return the regex pattern used to match excluded topics.
|
Executor |
executor() |
GoalOptimizer |
goalOptimizer() |
LoadMonitor |
loadMonitor() |
SbkAdminUtils |
sbkAdminUtils() |
boolean |
selfHealingEnabled() |
void |
selfHealingEnabled(boolean selfHealingEnabled) |
KafkaCruiseControl.CcStartupMode |
startupMode() |
org.apache.kafka.common.utils.Time |
time() |
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 Pattern excludedTopicsPattern()
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()
public void selfHealingEnabled(boolean selfHealingEnabled)
public boolean selfHealingEnabled()