fix

apache · Jan 2, 2025 · d3ab0e8 · d3ab0e8
1 parent f7b5628
commit d3ab0e8
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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);