🔥 Apply carried patches.

openshift-knative · Nov 14, 2021 · 0e4425d · 0e4425d
1 parent 8b3f286
commit 0e4425d
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 5 deletions.
diff --git a/pkg/common/client/config.go b/pkg/common/client/config.go
@@ -198,6 +198,7 @@ func (b *configBuilder) Build(ctx context.Context) (*sarama.Config, error) {
 
  // We Always Want Success Messages From Producer
  config.Producer.Return.Successes = true
+ config.Producer.RequiredAcks = sarama.WaitForAll
  }
 
  // then apply stuff from YAML

diff --git a/test/e2e/helpers/kafka_helper.go b/test/e2e/helpers/kafka_helper.go
@@ -47,7 +47,7 @@ const (
  strimziTopicResource = "kafkatopics"
  interval = 3 * time.Second
  timeout = 30 * time.Second
- kafkaCatImage = "docker.io/edenhill/kafkacat:1.6.0"
+ kafkaCatImage = "quay.io/openshift-knative/kafkacat:1.6.0"
 )
 
 var (

diff --git a/test/rekt/resources/kafkacat/kafkacat.yaml b/test/rekt/resources/kafkacat/kafkacat.yaml
@@ -19,7 +19,7 @@ metadata:
  namespace: {{ .namespace }}
 spec:
  containers:
- - image: docker.io/edenhill/kafkacat:1.6.0
+ - image: quay.io/openshift-knative/kafkacat:1.6.0
  name: producer-container
  command:
  - kafkacat

diff --git a/test/rekt/resources/kafkacat/kafkacat_test.go b/test/rekt/resources/kafkacat/kafkacat_test.go
@@ -51,7 +51,7 @@ func Example_min() {
  // namespace: bar
  // spec:
  // containers:
- // - image: docker.io/edenhill/kafkacat:1.6.0
+ // - image: quay.io/openshift-knative/kafkacat:1.6.0
  // name: producer-container
  // command:
  // - kafkacat
@@ -109,7 +109,7 @@ func Example_full() {
  // namespace: bar
  // spec:
  // containers:
- // - image: docker.io/edenhill/kafkacat:1.6.0
+ // - image: quay.io/openshift-knative/kafkacat:1.6.0
  // name: producer-container
  // command:
  // - kafkacat

diff --git a/vendor/knative.dev/pkg/version/version.go b/vendor/knative.dev/pkg/version/version.go
@@ -33,7 +33,7 @@ const (
  // NOTE: If you are changing this line, please also update the minimum kubernetes
  // version listed here:
  // https://github.com/knative/docs/blob/mkdocs/docs/snippets/prerequisites.md
- defaultMinimumVersion = "v1.20.0"
+ defaultMinimumVersion = "v1.19.0"
 )
 
 func getMinimumVersion() string {