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();
}