From 626f5b7c278880307390f770d41ee05515332142 Mon Sep 17 00:00:00 2001 From: Knative Prow Robot Date: Thu, 8 Feb 2024 13:49:18 +0000 Subject: [PATCH] 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 Co-authored-by: Pierangelo Di Pilato --- control-plane/pkg/reconciler/trigger/controller.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go index 9b87adf5a8..baa1b94bad 100644 --- 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{