@Override
        public void onAppend(TopicPartition partition, MemoryRecords records) {
            if (dirtyBytesCounter.addAndGet(records.sizeInBytes()) * decompressedRatio > config.incrementSyncThreshold()) {
                if (fastNextSync.compareAndSet(false, true)) {
                    eventLoop.submit(TopicPartitionsWorker.this::run);
                }
            }
        }
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