From 572e341da31ab216939b9a64ff739c1ad6f506b8 Mon Sep 17 00:00:00 2001 From: Alex Bozhenko Date: Mon, 27 Oct 2025 18:47:38 -0700 Subject: [PATCH 1/2] enalbe binary snapshots when server initally connects Signed-off-by: Alex Bozhenko --- server/route.go | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/server/route.go b/server/route.go index 008e6ede51c..3687b380775 100644 --- a/server/route.go +++ b/server/route.go @@ -2347,7 +2347,20 @@ func (s *Server) addRoute(c *client, didSolicit, sendDelayedInfo bool, gossipMod // check to be consistent and future proof. but will be same domain if s.sameDomain(info.Domain) { s.nodeToInfo.Store(rHash, - nodeInfo{rn, s.info.Version, s.info.Cluster, info.Domain, id, nil, nil, nil, false, info.JetStream, false, false}) + nodeInfo{ + name: rn, + version: s.info.Version, + cluster: s.info.Cluster, + domain: info.Domain, + id: id, + tags: nil, + cfg: nil, + stats: nil, + offline: false, + js: info.JetStream, + binarySnapshots: true, + accountNRG: false, + }) } } From a4a17f44d2bc63e65998b795e26ce520b2635966 Mon Sep 17 00:00:00 2001 From: Alex Bozhenko Date: Mon, 27 Oct 2025 18:58:08 -0700 Subject: [PATCH 2/2] add warning about legacy snapshot Signed-off-by: Alex Bozhenko --- server/jetstream_cluster.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index ab4a2b1e798..e3c426fe0f4 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -8769,6 +8769,7 @@ func (mset *stream) stateSnapshotLocked() []byte { Deleted: state.Deleted, } b, _ := json.Marshal(snap) + mset.srv.RateLimitWarnf("Stream %q: Using legacy JSON snapshot format. Snapshot length: %d bytes", mset.cfg.Name, len(b)) return b }