fix(auto_balancer): fix load balancer threshold (#1805)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Aug 15, 2024 · fd03fb4 · fd03fb4
1 parent f070e4e
commit fd03fb4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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;