diff --git a/server/jetstream.go b/server/jetstream.go index 5eba3c1c..da428b07 100644 --- a/server/jetstream.go +++ b/server/jetstream.go @@ -288,6 +288,10 @@ func (s *Server) DisableJetStream() error { if s.JetStreamIsClustered() { isLeader := s.JetStreamIsLeader() js, cc := s.getJetStreamCluster() + if js == nil { + s.shutdownJetStream() + return nil + } js.mu.RLock() meta := cc.meta js.mu.RUnlock()