private ReferenceHolder<Integer> tryAcquireMoreCommitQuota(int required) {
        for (; ; ) {
            int available = commitLimiter.availablePermits();
            int real = Math.min(available, required);
            if (commitLimiter.tryAcquire(real)) {
                return new ReferenceHolder<>(real, () -> commitLimiter.release(real));
            }
        }
    }
The flag to indicate the worker need reset. The worker status(writers) will be reset in the next round run.
core/src/main/java/kafka/automq/table/worker/TopicPartitionsWorker.java