public class KafkaDataBalanceManager extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ACTIVE_BALANCER_COUNT_METRIC_NAME |
static String |
BALANCER_STATE_METRIC_NAME |
static String |
BROKER_ADDITION_STATE_METRIC_NAME |
static String |
BROKER_REMOVAL_STATE_METRIC_NAME |
Constructor and Description |
---|
KafkaDataBalanceManager(kafka.server.KafkaConfig kafkaConfig,
Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpointOpt,
org.apache.kafka.common.utils.Time time)
Create a KafkaDataBalanceManager.
|
KafkaDataBalanceManager(kafka.server.KafkaConfig kafkaConfig,
org.apache.kafka.common.utils.Time time)
Create a KafkaDataBalanceManager without specifying bootstrap server endpoint.
|
Modifier and Type | Method and Description |
---|---|
kafka.common.BalancerStatusDescriptionInternal |
balancerStatus() |
BalancerStatusTracker |
balancerStatusTracker() |
List<kafka.common.BrokerRemovalDescriptionInternal> |
brokerRemovals()
Returns the latest state for each broker being removed
|
kafka.common.EvenClusterLoadStatusDescriptionInternal |
evenClusterLoadStatus() |
DataBalanceEngine |
getBalanceEngine() |
kafka.server.KafkaConfig |
getKafkaConfig() |
void |
handleEnableConfig(boolean sbcEnabledConfigValue,
Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadataOptional) |
void |
handleExcludeTopicsConfig(List<String> excludedNames,
List<String> excludedPrefixes,
String updatedRegex) |
void |
handleHealModeConfig(boolean shouldEnableImbalanceAutoHeal) |
void |
handleThrottleConfig(Long throttle) |
boolean |
isActive() |
void |
onAlteredExclusions(Set<Integer> newExclusions,
Set<Integer> removedExclusions) |
void |
onBrokerLeadershipPriorityChange(kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
Attempts to disable SBC if demoted brokers exist.
|
void |
onBrokersFailure(Set<Integer> deadBrokers) |
void |
onBrokersStartup(Set<Integer> emptyBrokers,
Set<Integer> newBrokers,
kafka.common.AliveBrokersMetadata brokersMetadata) |
void |
onElection(kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
Start-up the DataBalanceManager.
|
void |
onResignation()
When the broker ceases to be the primary DataBalancer in the cluster.
|
void |
scheduleBrokerRemoval(kafka.common.BrokerRemovalRequest removalRequest,
kafka.common.AliveBrokersMetadata brokersSnapshot) |
void |
shutdown()
To be called when the KafkaDataBalanceManager is being fully shut down, rather
than temporarily disabled for later startup.
|
long |
taskHistoryRetentionMs() |
void |
triggerEvenClusterLoadTask() |
void |
updateConfig(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig)
Updates the internal cruiseControl configuration based on dynamic property updates in the broker's KafkaConfig
|
public static final String ACTIVE_BALANCER_COUNT_METRIC_NAME
public static final String BROKER_REMOVAL_STATE_METRIC_NAME
public static final String BROKER_ADDITION_STATE_METRIC_NAME
public static final String BALANCER_STATE_METRIC_NAME
public KafkaDataBalanceManager(kafka.server.KafkaConfig kafkaConfig, org.apache.kafka.common.utils.Time time)
public KafkaDataBalanceManager(kafka.server.KafkaConfig kafkaConfig, Optional<org.apache.kafka.common.Endpoint> bootstrapServerEndpointOpt, org.apache.kafka.common.utils.Time time)
public void onElection(kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
public boolean isActive()
public BalancerStatusTracker balancerStatusTracker()
public void onResignation()
public void shutdown()
public void handleEnableConfig(boolean sbcEnabledConfigValue, Optional<kafka.common.AliveBrokersMetadata> aliveBrokersMetadataOptional)
public void handleThrottleConfig(Long throttle)
public void handleHealModeConfig(boolean shouldEnableImbalanceAutoHeal)
public void handleExcludeTopicsConfig(List<String> excludedNames, List<String> excludedPrefixes, String updatedRegex)
public void updateConfig(kafka.server.KafkaConfig oldConfig, kafka.server.KafkaConfig newConfig)
public void onBrokersStartup(Set<Integer> emptyBrokers, Set<Integer> newBrokers, kafka.common.AliveBrokersMetadata brokersMetadata)
public void onAlteredExclusions(Set<Integer> newExclusions, Set<Integer> removedExclusions)
public void onBrokerLeadershipPriorityChange(kafka.common.AliveBrokersMetadata aliveBrokersMetadata)
public List<kafka.common.BrokerRemovalDescriptionInternal> brokerRemovals()
public kafka.common.BalancerStatusDescriptionInternal balancerStatus()
public void triggerEvenClusterLoadTask()
public kafka.common.EvenClusterLoadStatusDescriptionInternal evenClusterLoadStatus()
public void scheduleBrokerRemoval(kafka.common.BrokerRemovalRequest removalRequest, kafka.common.AliveBrokersMetadata brokersSnapshot)
public DataBalanceEngine getBalanceEngine()
public kafka.server.KafkaConfig getKafkaConfig()
public long taskHistoryRetentionMs()