Prevent excessive wait time in KafkaSender for upgrade tests (knative…

…-extensions#1107) (knative-extensions#587) Co-authored-by: Martin Gencur <[email protected]> Co-authored-by: Knative Prow Robot <[email protected]> Co-authored-by: Martin Gencur <[email protected]>
matzew · Feb 24, 2022 · 6848d14 · 6848d14
1 parent 8a47a24
commit 6848d14
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/test/upgrade/continual/kafkasender.go b/test/upgrade/continual/kafkasender.go
@@ -74,6 +74,8 @@ func (k *kafkaSender) SendEvent(ce cloudevents.Event, rawEndpoint interface{}) e
 		WithClientId("continualtests-kafka-sender").
 		WithDefaults().
 		Build(k.ctx)
+	// Prevent excessive wait time.
+	conf.Producer.RequiredAcks = sarama.WaitForLocal
 	if err != nil {
 		return err
 	}