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 PopBufferMergeService { 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(