Fail when failed to acquire budget index (#855)

aklivity · Mar 17, 2024 · 6d21eb2 · 6d21eb2
1 parent f3859e8
commit 6d21eb2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...src/main/java/io/aklivity/zilla/runtime/engine/internal/budget/DefaultBudgetCreditor.java b/...src/main/java/io/aklivity/zilla/runtime/engine/internal/budget/DefaultBudgetCreditor.java
@@ -120,6 +120,10 @@ public long acquire(
                         System.nanoTime(), budgetId, budgetIndex);
             }
         }
+        else
+        {
+            throw new IllegalStateException(String.format("Failed to acquire budget index for budget %d", budgetId));
+        }
 
         return budgetIndex;
     }