private void cleanup() {
        try {
            List<ObjectStorage.ObjectInfo> objects = objectStorage.list(ZoneRouterPack.getObjectPathPrefix(currentNode.id())).get();
            objectStorage.delete(objects.stream().map(o -> (ObjectStorage.ObjectPath) o).collect(Collectors.toList())).get();
        } catch (Throwable e) {
            LOGGER.error("cleanup fail", e);
        }
    }
Split the produce request to different nodes
core/src/main/java/kafka/automq/zerozone/RouterOut.java