From d1251323343ea59c9ef89add033316aed4c548bc Mon Sep 17 00:00:00 2001 From: Selina Fehn Date: Thu, 6 Aug 2026 10:52:48 +0200 Subject: [PATCH 1/2] fix: set max messages to max 32 instead 128 --- pkg/pubsub/subscriber_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()) }) From 7206a950081168df72b7df8375bdbecdc76672a0 Mon Sep 17 00:00:00 2001 From: Selina Fehn Date: Thu, 6 Aug 2026 10:55:16 +0200 Subject: [PATCH 2/2] fix: set max messages to max 32 instead 128 or 64 --- pkg/pubsub/subscriber.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {