Fix overflow test

Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Aug 23, 2024 · ad081d9 · ad081d9
1 parent 549c1d0
commit ad081d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/jetstream/test/consumer_test.go b/jetstream/test/consumer_test.go
@@ -166,7 +166,7 @@ func TestConsumerOverflow(t *testing.T) {
 	}
 
 	// We are below overflow, so we should not get any moessages.
-	msgs, err := c.Fetch(10, jetstream.FetchMinPending(110), jetstream.FetchMaxWait(1*time.Second))
+	msgs, err := c.Fetch(10, jetstream.FetchMinPending(110), jetstream.FetchMaxWait(1*time.Second), jetstream.FetchGroup("A"))
 	count := 0
 	for msg := range msgs.Messages() {
 		msg.Ack()
@@ -181,7 +181,7 @@ func TestConsumerOverflow(t *testing.T) {
 		_, err = js.Publish(ctx, "FOO.bar", []byte("hello"))
 	}
 
-	msgs, err = c.Fetch(10, jetstream.FetchMinPending(110))
+	msgs, err = c.Fetch(10, jetstream.FetchMinPending(110), jetstream.FetchGroup("A"))
 	count = 0
 	for msg := range msgs.Messages() {
 		msg.Ack()