fix(test): reduce retry aggressiveness

IBM · Feb 25, 2022 · 43a4bee · 43a4bee
1 parent aacc766
commit 43a4bee
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/functional_producer_test.go b/functional_producer_test.go
@@ -351,8 +351,8 @@ func TestAsyncProducerRemoteBrokerClosed(t *testing.T) {
 	config.Net.MaxOpenRequests = 1
 	config.Producer.Flush.MaxMessages = 1
 	config.Producer.Return.Successes = true
-	config.Producer.Retry.Max = math.MaxInt32
-	config.Producer.Retry.Backoff = time.Millisecond
+	config.Producer.Retry.Max = 1024
+	config.Producer.Retry.Backoff = time.Millisecond * 50
 	config.Version, _ = ParseKafkaVersion(FunctionalTestEnv.KafkaVersion)
 
 	producer, err := NewAsyncProducer(