diff --git a/pkg/manager/manager.go b/pkg/manager/manager.go index 05edcdbb5a..cc5818f715 100644 --- a/pkg/manager/manager.go +++ b/pkg/manager/manager.go @@ -339,7 +339,13 @@ func New(config *rest.Config, options Options) (Manager, error) { if leaderConfig == nil { leaderConfig = rest.CopyConfig(config) } - resourceLock, err := options.newResourceLock(leaderConfig, recorderProvider, leaderelection.Options{ + + leaderRecorderProvider, err := options.newRecorderProvider(leaderConfig, cluster.GetScheme(), options.Logger.WithName("events"), options.makeBroadcaster) + if err != nil { + return nil, err + } + + resourceLock, err := options.newResourceLock(leaderConfig, leaderRecorderProvider, leaderelection.Options{ LeaderElection: options.LeaderElection, LeaderElectionResourceLock: options.LeaderElectionResourceLock, LeaderElectionID: options.LeaderElectionID,