Fix loading data from disk to cache on startup (#752)

iggy-rs · Mar 4, 2024 · f73e367 · f73e367
1 parent 9ddbe4a
commit f73e367
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 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.5"
+version = "0.2.6"
 edition = "2021"
 build = "src/build.rs"
 

diff --git a/server/src/streaming/segments/storage.rs b/server/src/streaming/segments/storage.rs
@@ -641,6 +641,7 @@ async fn load_messages_by_size(
 
         let payload_len = batch_length as usize;
         let mut payload = BytesMut::with_capacity(payload_len);
+        payload.put_bytes(0, payload_len);
         reader
             .read_exact(&mut payload)
             .await