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

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