diff --git a/server/jetstream.go b/server/jetstream.go index a6cbbfca..d9f94ef7 100644 --- a/server/jetstream.go +++ b/server/jetstream.go @@ -774,6 +774,10 @@ func (s *Server) migrateEphemerals() { var consumers []*consumerAssignment js.mu.Lock() + if cc.meta == nil { + js.mu.Unlock() + return + } ourID := cc.meta.ID() for _, asa := range cc.streams { for _, sa := range asa {