From ecdb9373927c2366680e86950fbf360705c0ad46 Mon Sep 17 00:00:00 2001
From: Matteo Merli <mmerli@apache.org>
Date: Wed, 28 Oct 2020 17:25:37 -0700
Subject: [PATCH] Fixed direct memory leak in proxy with trace logging enabled

---
 .../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..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);
         }