diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java
index 86bb1aa99320a..d7ed132c1d6c7 100644
--- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java
+++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java
@@ -188,6 +188,8 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
             compBuf.addComponents(totalSizeBuf,buffer);
             compBuf.writerIndex(totalSizeBuf.capacity()+buffer.capacity());
 
+            messages.forEach(RawMessage::release);
+
             //next handler
             ctx.fireChannelRead(compBuf);
         }