Fix message_cleaner buffered message stat (#882)

iggy-rs · Apr 7, 2024 · f5053af · f5053af
1 parent 3adbf6e
commit f5053af
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/server/Cargo.toml b/server/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "server"
-version = "0.2.15"
+version = "0.2.16"
 edition = "2021"
 build = "src/build.rs"
 

diff --git a/server/src/streaming/segments/messages.rs b/server/src/streaming/segments/messages.rs
@@ -296,8 +296,8 @@ impl Segment {
             return Ok(0);
         }
 
-        let unsaved_messages_number = unsaved_batches.first().unwrap().base_offset
-            + unsaved_batches.last().unwrap().get_last_offset();
+        let unsaved_messages_number = (unsaved_batches.last().unwrap().get_last_offset() + 1)
+            - unsaved_batches.first().unwrap().base_offset;
 
         trace!(
             "Saving {} messages on disk in segment with start offset: {} for partition with ID: {}...",