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

…-extensions#1107) (#588) Co-authored-by: Martin Gencur <mgencur@redhat.com> Co-authored-by: Knative Prow Robot <knative-prow-robot@google.com> Co-authored-by: Martin Gencur <mgencur@redhat.com>
openshift-knative · Feb 24, 2022 · e589f0e · e589f0e
1 parent bb1a5cf
commit e589f0e
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
 	}