private void completeWithError(Errors errors) {
            Map<TopicPartition, ProduceResponse.PartitionResponse> rst = new HashMap<>();
            topicPartitions.forEach(tp -> rst.put(tp, new ProduceResponse.PartitionResponse(errors, -1, -1, -1, -1, Collections.emptyList(), "")));
            cf.complete(rst);
        }
Split the produce request to different nodes
core/src/main/java/kafka/automq/zerozone/RouterOut.java