public class EngineInitializationContext extends Object
Modifier and Type | Class and Description |
---|---|
static class |
EngineInitializationContext.EngineStartupType |
Constructor and Description |
---|
EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig,
EngineInitializationContext.EngineStartupType howStarted,
Optional<kafka.common.AliveBrokersSnapshot> aliveBrokersSnapshotOpt,
io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry,
Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler,
BalancerStatusTracker balancerStatusTracker) |
public EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig, EngineInitializationContext.EngineStartupType howStarted, Optional<kafka.common.AliveBrokersSnapshot> aliveBrokersSnapshotOpt, io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry, Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler, BalancerStatusTracker balancerStatusTracker)
kafkaConfig
- - the Kafka confighowStarted
- -- whether the engine is being started by default (on a failover) or due to a configuration enablement.aliveBrokersSnapshotOpt
- - an optional of AliveBrokersSnapshot
,
consisting of the live broker IDs, their corresponding epoch at the time of initialization and other broker-related metadata.
This optional is empty when the engine is initialized via a configuration change (EngineInitializationContext.EngineStartupType.ON_ENABLE
).brokerRemovalMetricRegistry
- - a registry that allows us to register metrics tracking the broker removal statebrokerAdditionStateMetricRegistrationHandler
- - a function that takes in a broker ID as a parameter
and registers a metric that tracks the broker addition statebalancerStatusTracker
- - the Balancer status tracker