@Override
            public LoadLevel check() {
                return level;
            }
Should be called at the beginning of each test to initialize the manager.
core/src/test/java/kafka/automq/backpressure/DefaultBackPressureManagerTest.java