public class CruiseControlStartable
extends java.lang.Object
KafkaCruiseControl
instance,
like checking its necessary components can have their start up conditions met and
translating the #KafkaConfig
into #KafkaCruiseControlConfig
Constructor and Description |
---|
CruiseControlStartable(org.apache.kafka.common.utils.Time time,
DataBalancerMetricsRegistry dataBalancerMetricsRegistry) |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
generateClientConfigs(kafka.server.KafkaConfig config) |
KafkaCruiseControl |
startUp(kafka.server.KafkaConfig kafkaConfig,
java.util.concurrent.Semaphore abortStartupCheck)
Checks and initiates the necessary components for starting up the data balancer
(#
KafkaCruiseControl and returns an instance of it |
public CruiseControlStartable(org.apache.kafka.common.utils.Time time, DataBalancerMetricsRegistry dataBalancerMetricsRegistry)
public KafkaCruiseControl startUp(kafka.server.KafkaConfig kafkaConfig, java.util.concurrent.Semaphore abortStartupCheck) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
KafkaCruiseControl
and returns an instance of itabortStartupCheck
- - a #Semaphore
used for tracking when startup is abortedStartupCheckInterruptedException
- - when the startup has been interruptedjava.util.concurrent.ExecutionException
java.lang.InterruptedException
public static java.util.Map<java.lang.String,java.lang.Object> generateClientConfigs(kafka.server.KafkaConfig config)