Redis: fix capacity overflow error

SeaQL · Nov 26, 2024 · 98d5cfb · 98d5cfb
1 parent 84178ed
commit 98d5cfb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sea-streamer-redis/src/producer.rs b/sea-streamer-redis/src/producer.rs
@@ -446,6 +446,7 @@ pub(crate) async fn create_producer(
                                     break std::iter::repeat_with(|| {
                                         Err(StreamErr::Backend(err.clone()))
                                     })
+                                    .take(batch.0.len())
                                     .collect();
                                 }
                             }