diff --git a/pkg/pubsub/subscriber.go b/pkg/pubsub/subscriber.go
index f4b47af..60d4f74 100644
--- a/pkg/pubsub/subscriber.go
+++ b/pkg/pubsub/subscriber.go
@@ -134,7 +134,7 @@ func WithMaxMessages(maximum int32) PullOption {
 
 func (s *Subscriber) Pull(ctx context.Context, opts ...PullOption) (PullMessages, error) {
 	cfg := &pullOptions{
-		maxMessages: 64,
+		maxMessages: 32,
 	}
 
 	for _, opt := range opts {
diff --git a/pkg/pubsub/subscriber_test.go b/pkg/pubsub/subscriber_test.go
index 3f303f1..ac1994c 100644
--- a/pkg/pubsub/subscriber_test.go
+++ b/pkg/pubsub/subscriber_test.go
@@ -76,7 +76,7 @@ var _ = Describe("Pull messages", func() {
 
 		It("no error is occurring", func(ctx context.Context) {
 			subscriber := pubsub.NewSubscriber(topicId, subscriptionId, pubsub.WithHTTPRoundTripper(rt), pubsub.WithHost(environment))
-			resp, err := subscriber.Pull(ctx, pubsub.WithMaxMessages(128))
+			resp, err := subscriber.Pull(ctx, pubsub.WithMaxMessages(32))
 			Expect(resp).ToNot(BeNil())
 			Expect(err).ToNot(HaveOccurred())
 		})