private void assertRegulatorCalled(int increase, int decrease) {
        assertEquals(increase, regulatorIncreaseCalled);
        assertEquals(decrease, regulatorDecreaseCalled);
    }
Should be called at the beginning of each test to initialize the manager.
core/src/test/java/kafka/automq/backpressure/DefaultBackPressureManagerTest.java