Fixup

SeaQL · Nov 5, 2024 · b63c397 · b63c397
1 parent 9946b2f
commit b63c397
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sea-streamer-redis/src/producer.rs b/sea-streamer-redis/src/producer.rs
@@ -439,7 +439,7 @@ pub(crate) async fn create_producer(
                                 .send_async(Ok(MessageHeader::new(
                                     StreamKey::new(SEA_STREAMER_INTERNAL).unwrap(),
                                     Default::default(),
-                                    deleted as u64,
+                                    deleted.try_into().unwrap(),
                                     Timestamp::now_utc(),
                                 )))
                                 .await