From a3ac3c226f32b6fd8f6a31467f2dae66c4e24bb9 Mon Sep 17 00:00:00 2001 From: Knative Prow Robot Date: Thu, 8 Feb 2024 11:05:48 +0000 Subject: [PATCH] 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 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 536a0c1c32..2243f1ef8f 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{