[IMPROVED] Restart consumer behavior during healthz() checks. (#4172)

Signed-off-by: Derek Collison <derek@nats.io>

server/jetstream_cluster.go

@@ -475,6 +475,10 @@ func (js *jetStream) restartStream(acc *Account, csa *streamAssignment) {
 		js.mu.Lock()
 		ca := sa.consumers[cca.Name]
 		if ca != nil && ca.Group != nil {
+			// Make sure the node is stopped if still running.
+			if node := ca.Group.node; node != nil && node.State() != Closed {
+				node.Stop()
+			}
 			// Make sure node is wiped.
 			ca.Group.node = nil
 		}
@@ -543,6 +547,10 @@ func (js *jetStream) isConsumerHealthy(mset *stream, consumer string, ca *consum
 	restartConsumer := func() {
 		js.mu.Lock()
 		if ca.Group != nil {
+			// Make sure the node is stopped if still running.
+			if node := ca.Group.node; node != nil && node.State() != Closed {
+				node.Stop()
+			}
 			ca.Group.node = nil
 		}
 		deleted := ca.deleted