added label selector

knative-extensions · Mar 29, 2024 · d42ec72 · d42ec72
1 parent df52988
commit d42ec72
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/control-plane/cmd/kafka-controller/main.go b/control-plane/cmd/kafka-controller/main.go
@@ -27,6 +27,7 @@ import (
 	"knative.dev/pkg/injection/sharedmain"
 	"knative.dev/pkg/signals"
 
+	"knative.dev/eventing/pkg/auth"
 	"knative.dev/eventing/pkg/eventingtls"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
@@ -64,6 +65,7 @@ func main() {
 	ctx := signals.NewContext()
 	ctx = filteredFactory.WithSelectors(ctx,
 		eventingtls.TrustBundleLabelSelector,
+		auth.OIDCLabelSelector,
 	)
 	ctx = clientpool.WithKafkaClientPool(ctx)