private void updateDecompressedRatio() {
            MicroSyncBatchTask task = microSyncBatchTasks.get(0);
            double recordBatchSize = task.offsetBounds.stream().mapToLong(bound -> bound.end - bound.start).sum() * avgRecordSize;
            if (recordBatchSize == 0) {
                return;
            }
            TopicPartitionsWorker.this.updateDecompressedRatio(Math.max(task.ctx.writeSize / recordBatchSize, 1.0));
        }
Split sync task to parallel micro sync batch tasks.
core/src/main/java/kafka/automq/table/worker/TopicPartitionsWorker.java