diff --git a/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java b/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java index 8eba5d96fb..8394be6583 100644 --- a/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java +++ b/core/src/main/java/kafka/autobalancer/goals/AbstractResourceUsageDistributionGoal.java @@ -57,7 +57,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;