@Override
        public void regulate(Regulator regulator) {
            regulator.decrease();
        }
The system is in a high load state, and some actions should be taken to reduce the load.
core/src/main/java/kafka/automq/backpressure/LoadLevel.java