public class CruiseControlStartable extends 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 |
---|---|
KafkaCruiseControl |
createKafkaCruiseControl(kafka.server.KafkaConfig kafkaConfig,
EngineInitializationContext.EngineStartupType howStarted,
Semaphore abortStartupCheck)
Checks and initiates the necessary components for starting up the Kafka Cruise Control
(#
KafkaCruiseControl object and returns an instance of it |
static Map<String,Object> |
generateClientConfigs(kafka.server.KafkaConfig config) |
public CruiseControlStartable(org.apache.kafka.common.utils.Time time, DataBalancerMetricsRegistry dataBalancerMetricsRegistry)
public KafkaCruiseControl createKafkaCruiseControl(kafka.server.KafkaConfig kafkaConfig, EngineInitializationContext.EngineStartupType howStarted, Semaphore abortStartupCheck)
KafkaCruiseControl
object and returns an instance of ithowStarted
- -- indicate if start from FAILOVER (automatic) or ENABLE (user action)abortStartupCheck
- - a #Semaphore
used for tracking when startup is abortedStartupCheckInterruptedException
- - when the startup has been interrupted