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{