diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 187a0729e83..d293e49a50a 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -517,7 +517,7 @@ public void shutdown() { if (this.compactionService != null) { this.compactionService.shutdown(); } - if (messageStoreConfig.isRocksdbCQDoubleWriteEnable() && this.rocksDBMessageStore != null) { + if (this.rocksDBMessageStore != null && this.rocksDBMessageStore.consumeQueueStore != null) { this.rocksDBMessageStore.consumeQueueStore.shutdown(); } this.flushConsumeQueueService.shutdown();