This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 7742b7c12d [ISSUE #10157] Fix tiered metadata leak after topic delete 
(#10158)
7742b7c12d is described below

commit 7742b7c12d8bb83c2b54e0b517c02b44041b464a
Author: SHI <[email protected]>
AuthorDate: Tue Mar 17 10:15:00 2026 +0800

    [ISSUE #10157] Fix tiered metadata leak after topic delete (#10158)
    
    Co-authored-by: shixiaoxiao <[email protected]>
---
 .../org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
index eb726543cf..dd5a7a68a4 100644
--- 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
+++ 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
@@ -152,6 +152,7 @@ public class DefaultMetadataStore extends ConfigManager 
implements MetadataStore
     @Override
     public void deleteTopic(String topic) {
         topicMetadataTable.remove(topic);
+        queueMetadataTable.remove(topic);
         persist();
     }
 

Reply via email to