[ISSUE apache#8049] fix tiered store delete empty topic NPE (apache#8050

) Co-authored-by: zhaoyuhan <[email protected]>
Jianing-Xu · May 8, 2024 · ad02756 · ad02756
1 parent 5dae822
commit ad02756
Showing 1 changed file with 4 additions and 1 deletion.
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
@@ -164,7 +164,10 @@ public QueueMetadata getQueue(MessageQueue mq) {
 
     @Override
     public void iterateQueue(String topic, Consumer<QueueMetadata> callback) {
-        queueMetadataTable.get(topic).values().forEach(callback);
+        ConcurrentMap<Integer, QueueMetadata> metadataConcurrentMap = queueMetadataTable.get(topic);
+        if (metadataConcurrentMap != null) {
+            metadataConcurrentMap.values().forEach(callback);
+        }
     }
 
     @Override