diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 1b2c6be3..d0dbe93f 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -4127,6 +4127,7 @@ LOOP: return case <-notActive.C: s.Warnf("Did not receive all consumer info results for %q", acc) + resp.Error = NewJSClusterIncompleteError() break LOOP case ci := <-rc: resp.Consumers = append(resp.Consumers, ci)