From ee0a28d8a29bdb2e185dbfebbb6b17896ba590ef Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Markus=20Th=C3=B6mmes?= Date: Tue, 8 Jun 2021 18:16:34 +0200 Subject: [PATCH] Actually delete correct Kafka channel on cleanup --- test/e2ekafka/knative_kafka_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/e2ekafka/knative_kafka_test.go b/test/e2ekafka/knative_kafka_test.go index ce24a2fbfe..bfa575a10e 100644 --- a/test/e2ekafka/knative_kafka_test.go +++ b/test/e2ekafka/knative_kafka_test.go @@ -78,7 +78,7 @@ func TestKnativeKafka(t *testing.T) { } t.Cleanup(func() { - _ = caCtx.Clients.Kafka.MessagingV1beta1().KafkaChannels(knativeKafkaNamespace).Delete(context.Background(), "", metav1.DeleteOptions{}) + _ = caCtx.Clients.Kafka.MessagingV1beta1().KafkaChannels(knativeKafkaNamespace).Delete(context.Background(), ch.Name, metav1.DeleteOptions{}) }) t.Run("verify correct deployment shape for KafkaChannel", func(t *testing.T) {