diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
index 2e007c95a..f2821e016 100755
--- a/async-nats/tests/jetstream_tests.rs
+++ b/async-nats/tests/jetstream_tests.rs
@@ -2375,7 +2375,7 @@ mod jetstream {
                 .unwrap();
         }
 
-        let mut iter = consumer.fetch().max_messages(100).messages().await.unwrap();
+        let mut iter = consumer.batch().max_messages(10).messages().await.unwrap();
         client.flush().await.unwrap();
 
         tryhard::retry_fn(|| async {