[ISSUE #2345]🐛Fix broker start error (#2346)

mxsm · Jan 20, 2025 · 175be72 · 175be72
1 parent 6d3bb20
commit 175be72
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs b/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs
@@ -496,7 +496,8 @@ impl<MS: MessageStore> PopBufferMergeService<MS> {
 
     fn scan_commit_offset(&self) -> i32 {
         // Implement the logic to scan commit offset
-        unimplemented!()
+        warn!("scan_commit_offset not implemented");
+        0
     }
 
     pub fn add_ck_mock(