diff --git a/core/src/main/java/kafka/autobalancer/model/BrokerUpdater.java b/core/src/main/java/kafka/autobalancer/model/BrokerUpdater.java index 58a55ee683..36543f9246 100644 --- a/core/src/main/java/kafka/autobalancer/model/BrokerUpdater.java +++ b/core/src/main/java/kafka/autobalancer/model/BrokerUpdater.java @@ -102,7 +102,7 @@ public void addLoad(Resource resource, double delta) { public double utilizationFor(Resource resource) { double capacity = capacity(resource); if (capacity == 0) { - return 0; + return Double.MAX_VALUE; } return load(resource) / capacity(resource); }