From 175be72d19be434c34407abc7da06cb310d3e236 Mon Sep 17 00:00:00 2001
From: mxsm <mxsm@apache.org>
Date: Mon, 20 Jan 2025 15:41:29 +0800
Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2345]=F0=9F=90=9BFix=20broker=20start?=
 =?UTF-8?q?=20error=20(#2346)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../processor/processor_service/pop_buffer_merge_service.rs    | 3 ++-
 1 file changed, 2 insertions(+), 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
index eb941591..81ef0d70 100644
--- 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(