diff --git a/samples/snippets/src/test/java/pubsub/SubscriberIT.java b/samples/snippets/src/test/java/pubsub/SubscriberIT.java
index be9e4e3d2..f69acd8cb 100644
--- a/samples/snippets/src/test/java/pubsub/SubscriberIT.java
+++ b/samples/snippets/src/test/java/pubsub/SubscriberIT.java
@@ -165,19 +165,19 @@ public void testSubscriber() throws Exception {
       assertThat(bout.toString()).contains("Data: Hello " + i);
     }
 
-    publishSomeMessages(10);
+    publishSomeMessages(3);
     bout.reset();
     // Test subscribe synchronously.
     SubscribeSyncExample.subscribeSyncExample(projectId, subscriptionId, 10);
-    for (int i = 0; i < 10; i++) {
+    for (int i = 0; i < 3; i++) {
       assertThat(bout.toString()).contains("Hello " + i);
     }
 
-    publishSomeMessages(10);
+    publishSomeMessages(3);
     bout.reset();
     // Test subscribe synchronously with lease management.
     SubscribeSyncWithLeaseExample.subscribeSyncWithLeaseExample(projectId, subscriptionId, 10);
-    for (int i = 0; i < 10; i++) {
+    for (int i = 0; i < 3; i++) {
       assertThat(bout.toString()).contains("Hello " + i);
     }
   }