kgo testing: add UnknownTopicRetries(-1)

Failing in CI without unlimited retries (i.e. slow cluster).
twmb · Jan 21, 2024 · 636b45c · 636b45c
1 parent c07b329
commit 636b45c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kgo/consumer_direct_test.go b/pkg/kgo/consumer_direct_test.go
@@ -442,6 +442,7 @@ func TestIssue523(t *testing.T) {
 		MetadataMinAge(100*time.Millisecond),
 		FetchMaxWait(time.Second),
 		KeepRetryableFetchErrors(),
+		UnknownTopicRetries(-1),
 	)
 	defer cl.Close()
 
@@ -480,6 +481,7 @@ func TestSetOffsetsForNewTopic(t *testing.T) {
 			DefaultProduceTopic(t1),
 			MetadataMinAge(100*time.Millisecond),
 			FetchMaxWait(time.Second),
+			UnknownTopicRetries(-1),
 		)
 		defer cl.Close()