diff --git a/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java
index 83e86aab0771..321689ac8f56 100644
--- a/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java
@@ -58,6 +58,11 @@ public CleanConsumeQueueService createCleanConsumeQueueService() {
         return new RocksDBCleanConsumeQueueService();
     }
 
+    @Override
+    public FlushConsumeQueueService createFlushConsumeQueueService() {
+        return new RocksDBFlushConsumeQueueService();
+    }
+
     @Override
     public CorrectLogicOffsetService createCorrectLogicOffsetService() {
         return new RocksDBCorrectLogicOffsetService();
@@ -193,7 +198,6 @@ public void loadAndStartConsumerServiceOnly() {
                 throw new RuntimeException("load consume queue failed");
             }
             super.loadCheckPoint();
-            this.flushConsumeQueueService.start();
             this.consumeQueueStore.start();
         } catch (Exception e) {
             ERROR_LOG.error("loadAndStartConsumerServiceOnly error", e);