diff --git a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java index 86bae6e06c..5321670302 100644 --- a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java +++ b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java @@ -142,7 +142,7 @@ private void regulate(LoadLevel loadLevel, long now) { private Map stateMetrics() { LoadLevel current = currentLoadLevel(); for (LoadLevel level : LoadLevel.values()) { - int value = level.equals(current) ? 1 : -1; + int value = level.equals(current) ? current.ordinal() : -1; stateMetrics.put(level.name(), value); } return stateMetrics;