fix(s3stream): initialize broker capacity to ignored value (#526)

Signed-off-by: Shichao Nie <[email protected]>

core/src/main/java/kafka/autobalancer/model/BrokerUpdater.java

@@ -34,6 +34,7 @@
 
 public class BrokerUpdater {
     private static final Logger LOGGER = LoggerFactory.getLogger(BrokerUpdater.class);
+    private static final Double IGNORED_CAPACITY_VALUE = -1.0;
     private final Lock lock = new ReentrantLock();
     private final Broker broker;
 
@@ -51,6 +52,7 @@ public static class Broker {
 
         public Broker(int brokerId) {
             this.brokerId = brokerId;
+            Arrays.fill(this.brokerCapacity, IGNORED_CAPACITY_VALUE);
         }
 
         public Broker(Broker other) {
@@ -101,7 +103,10 @@ public void addLoad(Resource resource, double delta) {
 
         public double utilizationFor(Resource resource) {
             double capacity = capacity(resource);
-            if (capacity == 0) {
+            if (capacity == IGNORED_CAPACITY_VALUE) {
+                return 0.0;
+            }
+            if (capacity == 0.0) {
                 return Double.MAX_VALUE;
             }
             return load(resource) / capacity(resource);