public void replay(RemoveS3ObjectRecord record) {
        S3Object object = objectsMetadata.remove(record.objectId());
        if (object != null) {
            ObjectAttributes attributes = ObjectAttributes.from(object.getAttributes());
            // The DELETE composite object's size will be decrease when the object status becomes MARK_DESTROYED.
            if (!(attributes.type() == Type.Composite && !attributes.deepDelete())) {
                s3ObjectSize.set(s3ObjectSize.get() - object.getObjectSize());
            }
        }
        removePreparedObject(record.objectId());
        removeMarkDestroyedObject(record.objectId());
    }
The objectId of the next object to be prepared. (start from 0)
metadata/src/main/java/org/apache/kafka/controller/stream/S3ObjectControlManager.java