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.AliveBrokersMetadata> aliveBrokersMetadataOpt,
io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry,
Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler,
BalancerStatusTracker balancerStatusTracker) |
EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig,
Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpointOpt,
EngineInitializationContext.EngineStartupType howStarted,
Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadataOpt,
io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry,
Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler,
BalancerStatusTracker balancerStatusTracker) |
Modifier and Type | Method and Description |
---|---|
Optional<kafka.common.AliveBrokersMetadata> |
aliveBrokersMetadata() |
BalancerStatusTracker |
balancerStatusTracker() |
Optional<org.apache.kafka.common.Endpoint> |
bootstrapServerEndpoint() |
Function<Integer,AtomicReference<String>> |
brokerAdditionStateMetricRegistrationHandler() |
io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry |
brokerRemovalMetricRegistry() |
EngineInitializationContext.EngineStartupType |
engineStartupType() |
kafka.server.KafkaConfig |
kafkaConfig() |
public EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig, EngineInitializationContext.EngineStartupType howStarted, Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadataOpt, 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.aliveBrokersMetadataOpt
- - an optional of AliveBrokersMetadata
,
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
) in ZK-mode.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 trackerpublic EngineInitializationContext(kafka.server.KafkaConfig kafkaConfig, Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpointOpt, EngineInitializationContext.EngineStartupType howStarted, Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadataOpt, io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry, Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler, BalancerStatusTracker balancerStatusTracker)
kafkaConfig
- the Kafka configbootstrapServerEndpointOpt
- the endpoint that data balancer tries to connect to Kafka
cluster for the first time it will be set by KafkaController under ZooKeeper and be empty
under KRafthowStarted
- whether the engine is being started by default (on a failover) or due to a configuration enablement.aliveBrokersMetadataOpt
- an optional of AliveBrokersMetadata
,
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
) in ZK-mode.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 trackerpublic kafka.server.KafkaConfig kafkaConfig()
public Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpoint()
public Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadata()
public EngineInitializationContext.EngineStartupType engineStartupType()
public io.confluent.databalancer.KafkaDataBalanceManager.BrokerRemovalMetricRegistry brokerRemovalMetricRegistry()
public Function<Integer,AtomicReference<String>> brokerAdditionStateMetricRegistrationHandler()
public BalancerStatusTracker balancerStatusTracker()