Upgrade KafkaCat image used in KafkaSource e2e tests (#792)

Signed-off-by: Ahmed Abdalla <[email protected]> Co-authored-by: Ahmed Abdalla <[email protected]>
knative-extensions · Aug 5, 2021 · 1fc8e75 · 1fc8e75
1 parent a5e581a
commit 1fc8e75
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/test/e2e/helpers/kafka_helper.go b/test/e2e/helpers/kafka_helper.go
@@ -47,6 +47,7 @@ const (
 	strimziTopicResource = "kafkatopics"
 	interval             = 3 * time.Second
 	timeout              = 30 * time.Second
+	kafkaCatImage        = "docker.io/edenhill/kafkacat:1.6.0"
 )
 
 var (
@@ -102,7 +103,7 @@ func MustPublishKafkaMessage(client *testlib.Client, bootstrapServer string, top
 		},
 		Spec: corev1.PodSpec{
 			Containers: []corev1.Container{{
-				Image:   "docker.io/edenhill/kafkacat:1.5.0",
+				Image:   kafkaCatImage,
 				Name:    cgName + "-producer-container",
 				Command: []string{"kafkacat"},
 				Args:    args,