diff --git a/server/consumer.go b/server/consumer.go index c7891958eb9..fdc3e753f55 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -1010,7 +1010,9 @@ func (mset *stream) addConsumerWithAssignment(config *ConsumerConfig, oname stri // Check/update the pause state o.updatePauseState(&o.cfg) - o.sendPauseAdvisoryLocked(&o.cfg) + if time.Now().Before(o.cfg.PauseUntil) { + o.sendPauseAdvisoryLocked(&o.cfg) + } if o.isPushMode() { // Check if we are running only 1 replica and that the delivery subject has interest. @@ -1930,7 +1932,9 @@ func (o *consumer) updateConfig(cfg *ConsumerConfig) error { } if !cfg.PauseUntil.Equal(o.cfg.PauseUntil) { o.updatePauseState(cfg) - o.sendPauseAdvisoryLocked(cfg) + if o.isLeader() { + o.sendPauseAdvisoryLocked(cfg) + } } // Check for Subject Filters update.