diff --git a/test/rekt/features/kafka_source.go b/test/rekt/features/kafka_source.go
index 2dc16c2f6b..c823c10b24 100644
--- a/test/rekt/features/kafka_source.go
+++ b/test/rekt/features/kafka_source.go
@@ -22,6 +22,8 @@ import (
 	"fmt"
 	"strings"
 
+	"knative.dev/eventing/test/rekt/features/featureflags"
+
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	"github.com/cloudevents/sdk-go/v2/test"
 	. "github.com/cloudevents/sdk-go/v2/test"
@@ -556,6 +558,9 @@ func KafkaSourceTLSSink() *feature.Feature {
 	event.SetID(uuid.NewString())
 
 	f := feature.NewFeature()
+
+	f.Prerequisite("should not run when Istio is enabled", featureflags.IstioDisabled())
+
 	f.Setup("install kafka topic", kafkatopic.Install(topic))
 	f.Setup("topic is ready", kafkatopic.IsReady(topic))
 
@@ -603,6 +608,9 @@ func KafkaSourceTLSSinkTrustBundle() *feature.Feature {
 	event.SetID(uuid.NewString())
 
 	f := feature.NewFeature()
+
+	f.Prerequisite("should not run when Istio is enabled", featureflags.IstioDisabled())
+
 	f.Setup("install kafka topic", kafkatopic.Install(topic))
 	f.Setup("topic is ready", kafkatopic.IsReady(topic))