EngineInitializationContext
public EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig,
EngineInitializationContext.EngineStartupType howStarted,
Map<Integer,Long> brokerEpochs,
Function<Integer,AtomicReference<String>> brokerRemovalStateMetricRegistrationHandler,
Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler,
BalancerStatusTracker balancerStatusTracker)
- Parameters:
kafkaConfig
- - the Kafka config
howStarted
- -- whether the engine is being started by default (on a failover) or due to a configuration enablement.
brokerEpochs
- - a map consisting of broker ID and the corresponding broker's epoch at the time of initialization
brokerRemovalStateMetricRegistrationHandler
- - a function that takes in a broker ID as a parameter
and registers a metric that tracks the broker removal state
brokerAdditionStateMetricRegistrationHandler
- - a function that takes in a broker ID as a parameter
and registers a metric that tracks the broker addition state
balancerStatusTracker
- - the Balancer status tracker