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(ConfluentDataBalanceEngineContext confluentDataBalanceEngineContext,
EngineInitializationContext engineInitializationContext)
Creates
CruiseControlStartable , the cruise control and configuration factory. |
Modifier and Type | Method and Description |
---|---|
KafkaCruiseControl |
createKafkaCruiseControl(Semaphore abortStartupCheck)
Checks and initiates the necessary components for starting up the Kafka Cruise Control
(#
KafkaCruiseControl object and returns an instance of it |
OperationRetryer<KafkaCruiseControl> |
createStartupRetryer()
Creates a OperationRetryer to help startup SBC.
|
Map<String,Object> |
generateClientConfigs()
Generate client configs for the Admin client used by SBC when starting up SBC.
|
KafkaCruiseControlConfig |
generateCruiseControlConfig()
Given a #
KafkaConfig , generate an appropriate #KafkaCruiseControl to bring up CruiseControl internally. |
KafkaCruiseControlConfig |
kafkaCruiseControlConfig() |
public CruiseControlStartable(ConfluentDataBalanceEngineContext confluentDataBalanceEngineContext, EngineInitializationContext engineInitializationContext)
CruiseControlStartable
, the cruise control and configuration factory. Also generates
the cruise control configuration for future usage.confluentDataBalanceEngineContext
- ConfluentDataBalanceEngineContextengineInitializationContext
- EngineInitializationContextpublic KafkaCruiseControlConfig kafkaCruiseControlConfig()
public OperationRetryer<KafkaCruiseControl> createStartupRetryer()
OperationRetryer
public KafkaCruiseControl createKafkaCruiseControl(Semaphore abortStartupCheck)
KafkaCruiseControl
object and returns an instance of itabortStartupCheck
- - a #Semaphore
used for tracking when startup is abortedStartupCheckInterruptedException
- - when the startup has been interruptedpublic KafkaCruiseControlConfig generateCruiseControlConfig()
KafkaConfig
, generate an appropriate #KafkaCruiseControl
to bring up CruiseControl internally.
Visible for testingpublic Map<String,Object> generateClientConfigs()
Map
from config key (String) to config value (Object).