Use filtered global resync for triggers (#3682)

The current global resync accidently queues triggers that aren't associated with our brokers. Signed-off-by: Pierangelo Di Pilato <[email protected]> Co-authored-by: Pierangelo Di Pilato <[email protected]>
knative-extensions · Feb 8, 2024 · 626f5b7 · 626f5b7
1 parent a045337
commit 626f5b7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go
@@ -118,7 +118,7 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf
 	})
 
 	globalResync := func(_ interface{}) {
-		impl.GlobalResync(triggerInformer.Informer())
+		impl.FilteredGlobalResync(filterTriggers(reconciler.BrokerLister, kafka.BrokerClass, FinalizerName), triggerInformer.Informer())
 	}
 
 	configmapInformer.Informer().AddEventHandler(cache.FilteringResourceEventHandler{