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

apache · Dec 3, 2023 · 9d39d88 · 9d39d88
1 parent 66123ac
commit 9d39d88
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
@@ -242,6 +242,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;
             }