Use filtered global resync for triggers (#3681)

The current global resync accidently queues triggers that aren't associated with our brokers. Signed-off-by: Pierangelo Di Pilato <pierdipi@redhat.com> Co-authored-by: Pierangelo Di Pilato <pierdipi@redhat.com>
knative-extensions · Feb 8, 2024 · a3ac3c2 · a3ac3c2
1 parent fff36ac
commit a3ac3c2
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{