[fix][broker] Fix memory leak during topic compaction (apache#21647)

datastax · Dec 20, 2023 · 2f950fa · 2f950fa
1 parent 7ae661e
commit 2f950fa
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/compaction/TwoPhaseCompactor.java b/pulsar-broker/src/main/java/org/apache/pulsar/compaction/TwoPhaseCompactor.java
@@ -253,6 +253,7 @@ private void phaseTwoLoop(RawReader reader, MessageId to, Map<String, MessageId>
             }
 
             if (m.getMessageId().compareTo(lastCompactedMessageId) <= 0) {
+                m.close();
                 phaseTwoLoop(reader, to, latestForKey, lh, outstanding, promise, lastCompactedMessageId);
                 return;
             }