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

apache · Dec 4, 2023 · c8e9640 · c8e9640
1 parent dc7ba28
commit c8e9640
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
@@ -241,6 +241,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;
             }