public void add(Partition partition) {
        Map<Integer, Partition> newPartitions = new HashMap<>(partitions);
        newPartitions.put(partition.partitionId(), partition);
        partition.addAppendListener(advanceSync);
        this.partitions = newPartitions;
        requireReset = true;
        LOGGER.info("[ADD_PARTITION],{},{}", name, partition.partitionId());
    }
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