public CompletableFuture<Void> commit(CommitRequest commitRequest) {
        RequestWrapper request = new RequestWrapper(commitRequest);
        commitRequests.add(request);
        run();
        return request.cf;
    }
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