From d42ec725a3219bb0fefe3d3e9811bf7ae5d74e63 Mon Sep 17 00:00:00 2001 From: yijie-04 Date: Fri, 29 Mar 2024 10:53:11 -0400 Subject: [PATCH] added label selector --- control-plane/cmd/kafka-controller/main.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/control-plane/cmd/kafka-controller/main.go b/control-plane/cmd/kafka-controller/main.go index 1df7e207ed..4bfb67f309 100644 --- 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)