chore(backpressure): log it on back pressure (#2164)

Signed-off-by: Ning Yu <ningyu@automq.com>
AutoMQ · Nov 20, 2024 · 3073399 · 3073399
1 parent ff3b68e
commit 3073399
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/backpressure/DefaultBackPressureManager.java b/s3stream/src/main/java/com/automq/stream/s3/backpressure/DefaultBackPressureManager.java
@@ -121,6 +121,12 @@ private LoadLevel currentLoadLevel() {
     }
 
     private void regulate(LoadLevel loadLevel, long now) {
+        if (LoadLevel.NORMAL.equals(loadLevel) && LOGGER.isDebugEnabled()) {
+            LOGGER.debug("The system is in a normal state, checkers: {}", loadLevels);
+        } else {
+            LOGGER.info("The system is in a {} state, checkers: {}", loadLevel, loadLevels);
+        }
+
         loadLevel.regulate(regulator);
         lastRegulateTime = now;
     }