We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents dd29850 + 3aa9414 commit b94011eCopy full SHA for b94011e
server/jetstream_cluster.go
@@ -8765,6 +8765,13 @@ func (mset *stream) stateSnapshotLocked() []byte {
8765
}
8766
8767
// Older v1 version with deleted as a sorted []uint64.
8768
+ // For a stream with millions or billions of interior deletes, this will be huge.
8769
+ // Now that all server versions 2.10.+ support binary snapshots, we should never fall back.
8770
+ assert.Unreachable("Legacy JSON stream snapshot used", map[string]any{
8771
+ "stream": mset.cfg.Name,
8772
+ "account": mset.acc.Name,
8773
+ })
8774
+
8775
state := mset.store.State()
8776
snap := &streamSnapshot{
8777
Msgs: state.Msgs,
0 commit comments