diff --git a/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java b/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java index fc06588ae4..b61a9558c0 100644 --- a/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java +++ b/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java @@ -55,7 +55,7 @@ protected boolean requireMoreLoad(BrokerUpdater.Broker broker) { @Override public boolean isBrokerAcceptable(BrokerUpdater.Broker broker) { double load = broker.loadValue(resource()); - if (usageAvg < this.usageDetectThreshold) { + if (load < this.usageDetectThreshold && usageAvg < this.usageDetectThreshold) { return true; } return load >= usageDistLowerBound && load <= usageDistUpperBound;