public class SbcDataBalanceManager extends Object implements kafka.controller.DataBalanceManager
Constructor and Description |
---|
SbcDataBalanceManager(kafka.server.KafkaConfig kafkaConfig,
Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpoint)
Creates a SbcDataBalanceManager and conditionally set bootstrap server endpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
balancerStatus(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.BalancerStatusDescriptionInternal> cb) |
void |
brokerAdditions(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerAdditionDescriptionInternal>> cb) |
void |
brokerRemovals(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerRemovalDescriptionInternal>> cb) |
void |
cellLoad(List<Integer> cellIds,
kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.CellLoadDescriptionInternal> cb) |
void |
computeEvenClusterLoadPlan(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadPlanInternal> cb) |
void |
evenClusterLoadStatus(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadStatusDescriptionInternal> cb) |
KafkaDataBalanceManager |
getKafkaBalanceManager() |
void |
onAlteredExclusions(Set<Integer> newExclusions,
Set<Integer> removedExclusions) |
void |
onBrokerHealthChange(Set<Integer> newlyPromotedBrokers,
Set<Integer> newlyDemotedBrokers,
kafka.common.AliveBrokersMetadata aliveBrokersMetadata) |
void |
onBrokersFailure(Set<Integer> deadBrokers) |
void |
onBrokersStartup(Set<Integer> emptyBrokers,
Set<Integer> newBrokers,
kafka.common.AliveBrokersMetadata aliveBrokersMetadata) |
void |
onElection(kafka.common.AliveBrokersMetadata aliveBrokersMetadata) |
void |
onLeaderUpdate(org.apache.kafka.raft.LeaderAndEpoch leader) |
void |
onMetadataImageUpdate(org.apache.kafka.image.MetadataDelta metadataDelta,
org.apache.kafka.image.MetadataImage newMetadataImage) |
void |
onResignation() |
void |
scheduleKraftBrokerRemoval(List<Integer> brokersToRemove,
boolean shouldShutdown,
kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb) |
void |
scheduleZkBrokerRemoval(List<Integer> brokersToRemove,
boolean shouldShutdown,
kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot,
kafka.common.AliveBrokersMetadata aliveBrokersMetadata,
kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb) |
void |
shutdown()
Shutdown the SBC component completely (unlike resignation, which merely makes SBC inactive but
ready to resume operation).
|
void |
triggerEvenClusterLoadTask(kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb) |
void |
updateConfig(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
public SbcDataBalanceManager(kafka.server.KafkaConfig kafkaConfig, Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpoint)
ConfluentConfigs.BALANCER_CLASS_CONFIG
kafkaConfig
- - the kafka configbootstrapServerEndpoint
- - the bootstrap server endpoint, provided only when using ZooKeeperpublic void onLeaderUpdate(org.apache.kafka.raft.LeaderAndEpoch leader)
onLeaderUpdate
in interface org.apache.kafka.image.MetadataImageListener
public void onMetadataImageUpdate(org.apache.kafka.image.MetadataDelta metadataDelta, org.apache.kafka.image.MetadataImage newMetadataImage)
onMetadataImageUpdate
in interface org.apache.kafka.image.MetadataImageListener
public void shutdown()
shutdown
in interface kafka.controller.ClusterBalanceManager
public void scheduleZkBrokerRemoval(List<Integer> brokersToRemove, boolean shouldShutdown, kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot, kafka.common.AliveBrokersMetadata aliveBrokersMetadata, kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb)
scheduleZkBrokerRemoval
in interface kafka.controller.ClusterBalanceManager
public void scheduleKraftBrokerRemoval(List<Integer> brokersToRemove, boolean shouldShutdown, kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb)
scheduleKraftBrokerRemoval
in interface kafka.controller.ClusterBalanceManager
public void onBrokersStartup(Set<Integer> emptyBrokers, Set<Integer> newBrokers, kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
onBrokersStartup
in interface kafka.controller.ClusterBalanceManager
public void onBrokersFailure(Set<Integer> deadBrokers)
onBrokersFailure
in interface kafka.controller.ClusterBalanceManager
public void onAlteredExclusions(Set<Integer> newExclusions, Set<Integer> removedExclusions)
onAlteredExclusions
in interface kafka.controller.ClusterBalanceManager
public void brokerRemovals(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerRemovalDescriptionInternal>> cb)
brokerRemovals
in interface kafka.controller.ClusterBalanceManager
public void brokerAdditions(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerAdditionDescriptionInternal>> cb)
brokerAdditions
in interface kafka.controller.ClusterBalanceManager
public void balancerStatus(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.BalancerStatusDescriptionInternal> cb)
balancerStatus
in interface kafka.controller.ClusterBalanceManager
public void evenClusterLoadStatus(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadStatusDescriptionInternal> cb)
evenClusterLoadStatus
in interface kafka.controller.ClusterBalanceManager
public void triggerEvenClusterLoadTask(kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb)
triggerEvenClusterLoadTask
in interface kafka.controller.ClusterBalanceManager
public void computeEvenClusterLoadPlan(kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadPlanInternal> cb)
computeEvenClusterLoadPlan
in interface kafka.controller.ClusterBalanceManager
public void onBrokerHealthChange(Set<Integer> newlyPromotedBrokers, Set<Integer> newlyDemotedBrokers, kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
onBrokerHealthChange
in interface kafka.controller.ClusterBalanceManager
public void cellLoad(List<Integer> cellIds, kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.CellLoadDescriptionInternal> cb)
cellLoad
in interface kafka.controller.ClusterBalanceManager
public void onElection(kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
onElection
in interface kafka.controller.DataBalanceManager
public void onResignation()
onResignation
in interface kafka.controller.DataBalanceManager
public void updateConfig(kafka.server.KafkaConfig oldConfig, kafka.server.KafkaConfig newConfig)
updateConfig
in interface kafka.controller.DataBalanceManager
public KafkaDataBalanceManager getKafkaBalanceManager()