public void sync() {
            Optional<Map<Integer, Long>> startOffsetsOpt = getStartOffsets();
            if (startOffsetsOpt.isEmpty()) {
                return;
            }
            fastNextSync.set(false);
            SyncTask syncTask = newSyncTask("ADVANCED", startOffsetsOpt.get(), System.currentTimeMillis());
            syncTask.sync().whenCompleteAsync((task, e) -> {
                transitionTo(Status.IDLE);
                fastNextSync.set(task.hasMoreData());
                run();
            }, eventLoop);

        }
Try to sync the 'hot data' to the writer.
<p>
Note: it should run in event loop.
core/src/main/java/kafka/automq/table/worker/TopicPartitionsWorker.java