diff --git a/crates/core/src/db/message_log.rs b/crates/core/src/db/message_log.rs
index 53d269a82cf..f4858a851b4 100644
--- a/crates/core/src/db/message_log.rs
+++ b/crates/core/src/db/message_log.rs
@@ -195,6 +195,14 @@ impl std::fmt::Debug for MessageLog {
     }
 }
 
+impl Drop for MessageLog {
+    fn drop(&mut self) {
+        if let Err(e) = self.sync_all() {
+            log::warn!("Unable to fsync on drop: {e}");
+        }
+    }
+}
+
 // TODO: do we build the concept of batches into the message log?
 impl MessageLog {
     #[tracing::instrument(skip(path))]