fix oom error in publish path(apache#169)

fix oom error in publish path
hangc0276 · Aug 18, 2020 · 9ed74a9 · 9ed74a9
1 parent b6ed767
commit 9ed74a9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java
@@ -569,6 +569,7 @@ private void doPublishMessages(TopicName topic) {
                     } else {
                         result.getRight().complete(new PartitionResponse(Errors.NONE));
                     }
+                    headerAndPayload.release();
                 });
             } catch (Exception e) {
                 // should not comes here.