From c6ed73f33b1c0b32ac77ffb1f2f9814c1d79f991 Mon Sep 17 00:00:00 2001
From: rdhabalia <rdhabalia@apache.org>
Date: Wed, 2 Sep 2020 17:16:21 -0700
Subject: [PATCH] [pulsar-proxy] Fix memory leak with debug log-level

---
 .../java/org/apache/pulsar/proxy/server/ParserProxyHandler.java | 2 ++
 1 file changed, 2 insertions(+)

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..32f4ba73c43a1 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());
 
+            // Release mssages
+            messages.forEach(RawMessage::release);
             //next handler
             ctx.fireChannelRead(compBuf);
         }