diff --git a/pkg/reconciler/broker/controller.go b/pkg/reconciler/broker/controller.go index 4cbd880d84b..f6e104b10a8 100644 --- a/pkg/reconciler/broker/controller.go +++ b/pkg/reconciler/broker/controller.go @@ -18,6 +18,9 @@ package broker import ( "context" + "os" + + "knative.dev/pkg/injection" "knative.dev/eventing/pkg/auth" @@ -69,7 +72,12 @@ func NewController( logger := logging.FromContext(ctx) brokerInformer := brokerinformer.Get(ctx) subscriptionInformer := subscriptioninformer.Get(ctx) - endpointsInformer := namespacedinformerfactory.Get(ctx).Core().V1().Endpoints() + + endpointsInformer := namespacedinformerfactory.Get(ctx).Core().V1().Endpoints().Informer() + if err := controller.StartInformers(ctx.Done(), endpointsInformer); err != nil { + logger.Fatalw("Failed to start namespaced endpoints informer", zap.Error(err)) + } + configmapInformer := configmapinformer.Get(ctx) secretInformer := secretinformer.Get(ctx) eventPolicyInformer := eventpolicyinformer.Get(ctx)