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 index ad687d0497..a69a5735b4 100644 --- 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; }