@Override
        public void updateParentDir(File parentDir) {
            // noop implementation
        }
Only keep the last snapshot which offset less than or equals to the recoveryPointCheckpoint
core/src/main/scala/kafka/log/streamaspect/ElasticProducerStateManager.java