Rebase into master

Demogorgon314 · Jun 15, 2023 · d7894f4 · d7894f4
1 parent b92a984
commit d7894f4
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java
@@ -169,8 +169,11 @@ public CompletableFuture<Map<TopicPartition, ProduceResponse.PartitionResponse>>
                             Errors.forException(new InvalidTopicException(
                                     String.format("Cannot append to internal topic %s", topicPartition.topic())))));
                 } else {
-                    PartitionLog partitionLog =
-                            getPartitionLog(topicPartition, namespacePrefix);
+                    PartitionLog partitionLog = getPartitionLog(topicPartition, namespacePrefix);
+                    if (requiredAcks == 0) {
+                        partitionLog.appendRecords(memoryRecords, origin, appendRecordsContext);
+                        return;
+                    }
                     partitionLog.appendRecords(memoryRecords, origin, appendRecordsContext)
                             .thenAccept(offset -> addPartitionResponse.accept(topicPartition,
                                     new ProduceResponse.PartitionResponse(Errors.NONE, offset, -1L, -1L)))