diff --git a/sea-streamer-redis/src/producer.rs b/sea-streamer-redis/src/producer.rs
index 2f88e1c..9cb0ac9 100644
--- 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();
                                 }
                             }