fix(auto_balancer): fix load balancer threshold

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Aug 15, 2024 · fa2bf9e · fa2bf9e
1 parent 604533c
commit fa2bf9e
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
@@ -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;