diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 0ef749d6..94b928a9 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -1299,6 +1299,10 @@ func (js *jetStream) processAddPeer(peer string) { func (js *jetStream) processRemovePeer(peer string) { js.mu.Lock() s, cc := js.srv, js.cluster + if cc.meta == nil { + js.mu.Unlock() + return + } isLeader := cc.isLeader() // All nodes will check if this is them. isUs := cc.meta.ID() == peer