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
index beb059b420..c23ae9724c 100644
--- 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.