diff --git a/server/stream.go b/server/stream.go index f1ba0c27678..5f7066cb77b 100644 --- a/server/stream.go +++ b/server/stream.go @@ -5121,6 +5121,10 @@ func (mset *stream) name() string { func (mset *stream) internalLoop() { mset.mu.RLock() + setGoRoutineLabels(pprofLabels{ + "account": mset.acc.Name, + "stream": mset.cfg.Name, + }) s := mset.srv c := s.createInternalJetStreamClient() c.registerWithAccount(mset.acc)