Add some margin to slow test.

nachogiljaldo · nachogiljaldo · commit fb863b8e6967 · 2024-11-15T23:41:19.000+01:00
diff --git a/reader_test.go b/reader_test.go
@@ -364,7 +364,7 @@ func waitForTopic(ctx context.Context, t *testing.T, topic string) {
 			}
 		}
 
-		t.Logf("retrying after 1s")
+		t.Logf("retrying after 100ms")
 		time.Sleep(100 * time.Millisecond)
 		continue
 	}
@@ -1560,7 +1560,7 @@ func TestConsumerGroupWithGroupTopicsSingle(t *testing.T) {
 }
 
 func TestConsumerGroupWithGroupTopicsMultiple(t *testing.T) {
-	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
 	defer cancel()
 
 	client, shutdown := newLocalClient()

Original file line number	Diff line number	Diff line change
`@@ -364,7 +364,7 @@ func waitForTopic(ctx context.Context, t *testing.T, topic string) {`
`364`	`364`	`}`
`365`	`365`	`}`
`366`	`366`
`367`		`- t.Logf("retrying after 1s")`
	`367`	`+ t.Logf("retrying after 100ms")`
`368`	`368`	`time.Sleep(100 * time.Millisecond)`
`369`	`369`	`continue`
`370`	`370`	`}`
`@@ -1560,7 +1560,7 @@ func TestConsumerGroupWithGroupTopicsSingle(t *testing.T) {`
`1560`	`1560`	`}`
`1561`	`1561`
`1562`	`1562`	`func TestConsumerGroupWithGroupTopicsMultiple(t *testing.T) {`
`1563`		`- ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)`
	`1563`	`+ ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)`
`1564`	`1564`	`defer cancel()`
`1565`	`1565`
`1566`	`1566`	`client, shutdown := newLocalClient()`