Skip to content

Commit e6b0021

Browse files
[release-1.13] Skip KafkaSource TLS tests on Istio (#3640)
* Skip KafkaSource TLS tests on Istio * Run goimport --------- Co-authored-by: Christoph Stäbler <[email protected]>
1 parent 1683a04 commit e6b0021

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

test/rekt/features/kafka_source.go

+8
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@ import (
2222
"fmt"
2323
"strings"
2424

25+
"knative.dev/eventing/test/rekt/features/featureflags"
26+
2527
cloudevents "github.com/cloudevents/sdk-go/v2"
2628
"github.com/cloudevents/sdk-go/v2/test"
2729
. "github.com/cloudevents/sdk-go/v2/test"
@@ -556,6 +558,9 @@ func KafkaSourceTLSSink() *feature.Feature {
556558
event.SetID(uuid.NewString())
557559

558560
f := feature.NewFeature()
561+
562+
f.Prerequisite("should not run when Istio is enabled", featureflags.IstioDisabled())
563+
559564
f.Setup("install kafka topic", kafkatopic.Install(topic))
560565
f.Setup("topic is ready", kafkatopic.IsReady(topic))
561566

@@ -603,6 +608,9 @@ func KafkaSourceTLSSinkTrustBundle() *feature.Feature {
603608
event.SetID(uuid.NewString())
604609

605610
f := feature.NewFeature()
611+
612+
f.Prerequisite("should not run when Istio is enabled", featureflags.IstioDisabled())
613+
606614
f.Setup("install kafka topic", kafkatopic.Install(topic))
607615
f.Setup("topic is ready", kafkatopic.IsReady(topic))
608616

0 commit comments

Comments
 (0)