diff --git a/nomad/leader.go b/nomad/leader.go
index 33c345c88bf75a25ba854a79de4a238733772165..05977d746db461b3730c742725bdfd1e5da4d45b 100644
--- a/nomad/leader.go
+++ b/nomad/leader.go
@@ -853,6 +853,10 @@ func (s *Server) publishJobStatusMetrics(stopCh chan struct{}) {
 }
 
 func (s *Server) publishEventsForSinks(stopCh chan struct{}) {
+	broker, err := s.State().EventBroker()
+	if err != nil {
+		s.logger.Warn("event broker not enabled on leader", "error", err)
+	}
 
 	for {
 		select {